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, preparepublic List<List<Values>> batchRetrieve(JdbcState jdbcState, List<TridentTuple> tridentTuples)
public void execute(TridentTuple tuples, List<Values> values, TridentCollector tridentCollector)
Copyright © 2021 The Apache Software Foundation. All rights reserved.