OUT
- type of Tuplepublic class CassandraInputFormat<OUT extends Tuple> extends CassandraInputFormatBase<OUT>
Tuple
.cluster, logger, query, session
Constructor and Description |
---|
CassandraInputFormat(String query,
ClusterBuilder builder) |
Modifier and Type | Method and Description |
---|---|
OUT |
nextRecord(OUT reuse)
Reads the next record from the input.
|
void |
open(InputSplit ignored)
Opens a Session and executes the query.
|
boolean |
reachedEnd()
Method used to check if the end of the input is reached.
|
close, configure, createInputSplits, getInputSplitAssigner, getStatistics
closeInputFormat, getRuntimeContext, openInputFormat, setRuntimeContext
public CassandraInputFormat(String query, ClusterBuilder builder)
public void open(InputSplit ignored) throws IOException
ignored
- because parameter is not parallelizable.IOException
public boolean reachedEnd() throws IOException
InputFormat
When this method is called, the input format it guaranteed to be opened.
IOException
- Thrown, if an I/O error occurred.public OUT nextRecord(OUT reuse) throws IOException
InputFormat
When this method is called, the input format it guaranteed to be opened.
reuse
- Object that may be reused.IOException
- Thrown, if an I/O error occurred.Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.