public class HCatInputFormat<T> extends HCatInputFormatBase<T>
Data can be returned as HCatRecord
or Scala tuples.
Scala tuples support only up to 22 fields.
fieldNames, outputSchema
Constructor and Description |
---|
HCatInputFormat(String database,
String table) |
HCatInputFormat(String database,
String table,
org.apache.hadoop.conf.Configuration config) |
Modifier and Type | Method and Description |
---|---|
protected T |
buildFlinkTuple(T t,
org.apache.hive.hcatalog.data.HCatRecord record) |
void |
configure(Configuration parameters)
Configures this input format.
|
protected int |
getMaxFlinkTupleSize() |
Object[] |
vals() |
asFlinkTuples, close, createInputSplits, getConfiguration, getFields, getInputSplitAssigner, getOutputSchema, getProducedType, getStatistics, nextRecord, open, reachedEnd, withFilter
closeInputFormat, getRuntimeContext, openInputFormat, setRuntimeContext
public HCatInputFormat(String database, String table, org.apache.hadoop.conf.Configuration config)
public Object[] vals()
public void configure(Configuration parameters)
InputFormat
This method is always called first on a newly instantiated input format.
configure
in interface InputFormat<T,HadoopInputSplit>
configure
in class HCatInputFormatBase<T>
parameters
- The configuration with all parameters.protected int getMaxFlinkTupleSize()
getMaxFlinkTupleSize
in class HCatInputFormatBase<T>
protected T buildFlinkTuple(T t, org.apache.hive.hcatalog.data.HCatRecord record)
buildFlinkTuple
in class HCatInputFormatBase<T>
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.