public class JdbcQuery extends BaseQueryFunction<JdbcState,List<Values>>
Constructor and Description |
---|
JdbcQuery() |
Modifier and Type | Method and Description |
---|---|
List<List<Values>> |
batchRetrieve(JdbcState jdbcState,
List<TridentTuple> tridentTuples) |
void |
execute(TridentTuple tuples,
List<Values> values,
TridentCollector tridentCollector) |
cleanup, prepare
public List<List<Values>> batchRetrieve(JdbcState jdbcState, List<TridentTuple> tridentTuples)
public void execute(TridentTuple tuples, List<Values> values, TridentCollector tridentCollector)
Copyright © 2022 The Apache Software Foundation. All rights reserved.