org.apache.flink.addons.hbase1

Class TableInputFormat<T extends Tuple>

java.lang.Object

org.apache.flink.api.common.io.RichInputFormat<T,TableInputSplit>

org.apache.flink.connector.hbase1.source.AbstractTableInputFormat<T>

org.apache.flink.connector.hbase1.source.HBaseInputFormat<T>

org.apache.flink.addons.hbase1.TableInputFormat<T>

All Implemented Interfaces:

Serializable, InputFormat<T,TableInputSplit>, InputSplitSource<TableInputSplit>

Deprecated.

please use HBaseInputFormat.

@Deprecated
public abstract class TableInputFormat<T extends Tuple>
extends HBaseInputFormat<T>

InputFormat subclass that wraps the access for HTables.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.flink.connector.hbase1.source.AbstractTableInputFormat

connection, currentRow, endReached, LOG, resultScanner, scan, scannedRows, serializedConfig, table

Constructor Summary

Constructors

Constructor and Description
TableInputFormat(Configuration hConf) Deprecated.

Method Summary

Methods inherited from class org.apache.flink.connector.hbase1.source.HBaseInputFormat

getScanner, getTableName, initTable, mapResultToOutType, mapResultToTuple

Methods inherited from class org.apache.flink.connector.hbase1.source.AbstractTableInputFormat

close, closeTable, configure, createInputSplits, getConnection, getHadoopConfiguration, getInputSplitAssigner, getStatistics, includeRegionInScan, nextRecord, open, reachedEnd

Methods inherited from class org.apache.flink.api.common.io.RichInputFormat

closeInputFormat, getRuntimeContext, openInputFormat, setRuntimeContext

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TableInputFormat

public TableInputFormat(Configuration hConf)

Deprecated.