T
- public class HCatInputFormat<T> extends HCatInputFormatBase<T>
HCatRecord
or Flink Tuple
.
Flink tuples support only up to 25 fields.fieldNames, outputSchema
Constructor and Description |
---|
HCatInputFormat() |
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) |
protected int |
getMaxFlinkTupleSize() |
asFlinkTuples, close, configure, createInputSplits, getConfiguration, getFields, getInputSplitAssigner, getOutputSchema, getProducedType, getStatistics, nextRecord, open, reachedEnd, withFilter
closeInputFormat, getRuntimeContext, openInputFormat, setRuntimeContext
public HCatInputFormat()
public HCatInputFormat(String database, String table) throws Exception
Exception
protected int getMaxFlinkTupleSize()
getMaxFlinkTupleSize
in class HCatInputFormatBase<T>
protected T buildFlinkTuple(T t, org.apache.hive.hcatalog.data.HCatRecord record) throws org.apache.hive.hcatalog.common.HCatException
buildFlinkTuple
in class HCatInputFormatBase<T>
org.apache.hive.hcatalog.common.HCatException
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.