Modifier and Type | Method and Description |
---|---|
void |
StatementAgentInstanceFactoryCreateTable.setAggregationSerde(DataInputOutputSerde aggregationSerde) |
void |
StatementAgentInstanceFactoryCreateTable.setPrimaryKeySerde(DataInputOutputSerde<Object> primaryKeySerde) |
void |
StatementAgentInstanceFactoryCreateTable.setPropertyForges(DataInputOutputSerde[] propertyForges) |
Modifier and Type | Method and Description |
---|---|
DataInputOutputSerde<Object> |
ContextControllerDetailInitiatedTerminated.getDistinctSerde() |
Modifier and Type | Method and Description |
---|---|
void |
ContextControllerDetailInitiatedTerminated.setDistinctSerde(DataInputOutputSerde<Object> distinctSerde) |
Modifier and Type | Method and Description |
---|---|
DataInputOutputSerde<Object> |
ContextControllerDetailKeyedItem.getKeySerde() |
Modifier and Type | Method and Description |
---|---|
void |
ContextControllerDetailKeyedItem.setKeySerde(DataInputOutputSerde<Object> keySerde) |
Modifier and Type | Method and Description |
---|---|
DataInputOutputSerde[] |
ContextServiceFactoryDefault.getContextPartitionKeyBindings(ContextDefinition contextDefinition) |
DataInputOutputSerde[] |
ContextServiceFactory.getContextPartitionKeyBindings(ContextDefinition contextDefinition) |
DataInputOutputSerde[] |
ContextManagerResident.getContextPartitionKeySerdes() |
DataInputOutputSerde[] |
ContextManager.getContextPartitionKeySerdes() |
DataInputOutputSerde[] |
ContextManagerResident.getContextPartitionKeySerdeSubset(int nestingLevel) |
static DataInputOutputSerde[] |
ContextManagerResident.getContextPartitionKeySerdeSubset(int nestingLevel,
DataInputOutputSerde[] allSerdes) |
Modifier and Type | Method and Description |
---|---|
ContextPartitionIdService |
ContextServiceFactoryDefault.getContextPartitionIdService(StatementContext statementContextCreateContext,
DataInputOutputSerde[] bindings,
StateMgmtSetting stateMgmtSettings) |
ContextPartitionIdService |
ContextServiceFactory.getContextPartitionIdService(StatementContext statementContextCreateContext,
DataInputOutputSerde[] bindings,
StateMgmtSetting stateMgmtSettings) |
static DataInputOutputSerde[] |
ContextManagerResident.getContextPartitionKeySerdeSubset(int nestingLevel,
DataInputOutputSerde[] allSerdes) |
Modifier and Type | Method and Description |
---|---|
void |
EPStatementInitServices.activateVariable(String name,
DataInputOutputSerde<Object> serde) |
Modifier and Type | Method and Description |
---|---|
DataInputOutputSerde[] |
AggregationGroupByRollupDesc.getKeySerdes() |
DataInputOutputSerde<Object> |
AggregationGroupByRollupLevel.getSubkeySerde() |
Constructor and Description |
---|
AggregationGroupByRollupLevel(int levelNumber,
int levelOffset,
int[] rollupKeys,
DataInputOutputSerde<Object> subkeySerde) |
Modifier and Type | Method and Description |
---|---|
DataInputOutputSerde<Object> |
AggregationLocalGroupByLevel.getKeySerde() |
DataInputOutputSerde |
AggregationLocalGroupByLevel.getRowSerde() |
Constructor and Description |
---|
AggregationLocalGroupByLevel(AggregationRowFactory rowFactory,
DataInputOutputSerde rowSerde,
EPType[] groupKeyTypes,
ExprEvaluator groupKeyEval,
boolean isDefaultLevel,
DataInputOutputSerde<Object> keySerde) |
AggregationLocalGroupByLevel(AggregationRowFactory rowFactory,
DataInputOutputSerde rowSerde,
EPType[] groupKeyTypes,
ExprEvaluator groupKeyEval,
boolean isDefaultLevel,
DataInputOutputSerde<Object> keySerde) |
Modifier and Type | Method and Description |
---|---|
static AggregationNthState |
AggregatorNthSerde.read(DataInput input,
byte[] unitKey,
DataInputOutputSerde serdeNullable,
int sizeBuf)
NOTE: Code-generation-invoked method, method name and parameter order matters
|
static void |
AggregatorNthSerde.write(DataOutput output,
byte[] unitKey,
EventBeanCollatedWriter writer,
DataInputOutputSerde serdeNullable,
Object[] circularBuffer,
long numDataPoints,
int currentBufferElementPointer,
int sizeBuf)
NOTE: Code-generation-invoked method, method name and parameter order matters
|
Modifier and Type | Method and Description |
---|---|
DataInputOutputSerde<Object> |
ExprFilterSpecLookupable.getValueSerde() |
Constructor and Description |
---|
ExprFilterSpecLookupable(String expression,
ExprEventEvaluator eval,
ExprEvaluator expr,
EPTypeClass returnType,
boolean isNonPropertyEval,
DataInputOutputSerde<Object> valueSerde) |
Modifier and Type | Method and Description |
---|---|
static EventTable |
EventTableUtil.buildIndex(AgentInstanceContext agentInstanceContext,
int indexedStreamNum,
QueryPlanIndexItem item,
EventType eventType,
boolean unique,
String optionalIndexName,
DataInputOutputSerde<Object> optionalValueSerde,
boolean isFireAndForget)
Build an index/table instance using the event properties for the event type.
|
EventTableFactory |
EventTableIndexServiceImpl.createComposite(int indexedStreamNum,
EventType eventType,
String[] indexProps,
EPTypeClass[] indexCoercionTypes,
EventPropertyValueGetter indexGetter,
MultiKeyFromObjectArray transformFireAndForget,
DataInputOutputSerde<Object> keySerde,
String[] rangeProps,
EPTypeClass[] rangeCoercionTypes,
EventPropertyValueGetter[] rangeGetters,
DataInputOutputSerde<Object>[] rangeSerdes,
DataInputOutputSerde<Object> optionalValueSerde,
boolean isFireAndForget) |
EventTableFactory |
EventTableIndexServiceImpl.createComposite(int indexedStreamNum,
EventType eventType,
String[] indexProps,
EPTypeClass[] indexCoercionTypes,
EventPropertyValueGetter indexGetter,
MultiKeyFromObjectArray transformFireAndForget,
DataInputOutputSerde<Object> keySerde,
String[] rangeProps,
EPTypeClass[] rangeCoercionTypes,
EventPropertyValueGetter[] rangeGetters,
DataInputOutputSerde<Object>[] rangeSerdes,
DataInputOutputSerde<Object> optionalValueSerde,
boolean isFireAndForget) |
EventTableFactory |
EventTableIndexServiceImpl.createComposite(int indexedStreamNum,
EventType eventType,
String[] indexProps,
EPTypeClass[] indexCoercionTypes,
EventPropertyValueGetter indexGetter,
MultiKeyFromObjectArray transformFireAndForget,
DataInputOutputSerde<Object> keySerde,
String[] rangeProps,
EPTypeClass[] rangeCoercionTypes,
EventPropertyValueGetter[] rangeGetters,
DataInputOutputSerde<Object>[] rangeSerdes,
DataInputOutputSerde<Object> optionalValueSerde,
boolean isFireAndForget) |
EventTableFactory |
EventTableIndexService.createComposite(int indexedStreamNum,
EventType eventType,
String[] indexProps,
EPTypeClass[] indexCoercionTypes,
EventPropertyValueGetter indexGetter,
MultiKeyFromObjectArray transformFireAndForget,
DataInputOutputSerde<Object> keySerde,
String[] rangeProps,
EPTypeClass[] rangeCoercionTypes,
EventPropertyValueGetter[] rangeGetters,
DataInputOutputSerde<Object>[] rangeSerdes,
DataInputOutputSerde<Object> optionalValueSerde,
boolean isFireAndForget) |
EventTableFactory |
EventTableIndexService.createComposite(int indexedStreamNum,
EventType eventType,
String[] indexProps,
EPTypeClass[] indexCoercionTypes,
EventPropertyValueGetter indexGetter,
MultiKeyFromObjectArray transformFireAndForget,
DataInputOutputSerde<Object> keySerde,
String[] rangeProps,
EPTypeClass[] rangeCoercionTypes,
EventPropertyValueGetter[] rangeGetters,
DataInputOutputSerde<Object>[] rangeSerdes,
DataInputOutputSerde<Object> optionalValueSerde,
boolean isFireAndForget) |
EventTableFactory |
EventTableIndexService.createComposite(int indexedStreamNum,
EventType eventType,
String[] indexProps,
EPTypeClass[] indexCoercionTypes,
EventPropertyValueGetter indexGetter,
MultiKeyFromObjectArray transformFireAndForget,
DataInputOutputSerde<Object> keySerde,
String[] rangeProps,
EPTypeClass[] rangeCoercionTypes,
EventPropertyValueGetter[] rangeGetters,
DataInputOutputSerde<Object>[] rangeSerdes,
DataInputOutputSerde<Object> optionalValueSerde,
boolean isFireAndForget) |
EventTableFactory |
EventTableIndexServiceImpl.createHashedOnly(int indexedStreamNum,
EventType eventType,
String[] indexProps,
MultiKeyFromObjectArray transformFireAndForget,
DataInputOutputSerde<Object> keySerde,
boolean unique,
String optionalIndexName,
EventPropertyValueGetter getter,
DataInputOutputSerde<Object> optionalValueSerde,
boolean isFireAndForget,
StateMgmtSetting stateMgmtSettings) |
EventTableFactory |
EventTableIndexServiceImpl.createHashedOnly(int indexedStreamNum,
EventType eventType,
String[] indexProps,
MultiKeyFromObjectArray transformFireAndForget,
DataInputOutputSerde<Object> keySerde,
boolean unique,
String optionalIndexName,
EventPropertyValueGetter getter,
DataInputOutputSerde<Object> optionalValueSerde,
boolean isFireAndForget,
StateMgmtSetting stateMgmtSettings) |
EventTableFactory |
EventTableIndexService.createHashedOnly(int indexedStreamNum,
EventType eventType,
String[] indexProps,
MultiKeyFromObjectArray transformFireAndForget,
DataInputOutputSerde<Object> keySerde,
boolean unique,
String optionalIndexName,
EventPropertyValueGetter getter,
DataInputOutputSerde<Object> optionalValueSerde,
boolean isFireAndForget,
StateMgmtSetting stateMgmtSettings) |
EventTableFactory |
EventTableIndexService.createHashedOnly(int indexedStreamNum,
EventType eventType,
String[] indexProps,
MultiKeyFromObjectArray transformFireAndForget,
DataInputOutputSerde<Object> keySerde,
boolean unique,
String optionalIndexName,
EventPropertyValueGetter getter,
DataInputOutputSerde<Object> optionalValueSerde,
boolean isFireAndForget,
StateMgmtSetting stateMgmtSettings) |
EventTableFactory |
EventTableIndexServiceImpl.createInArray(int streamNum,
EventType eventType,
String[] propertyNames,
EPTypeClass[] indexTypes,
DataInputOutputSerde<Object>[] indexSerdes,
boolean unique,
EventPropertyValueGetter[] getters,
boolean isFireAndForget,
StateMgmtSetting stateMgmtSettings) |
EventTableFactory |
EventTableIndexService.createInArray(int streamNum,
EventType eventType,
String[] propertyNames,
EPTypeClass[] indexTypes,
DataInputOutputSerde<Object>[] indexSerdes,
boolean unique,
EventPropertyValueGetter[] getters,
boolean isFireAndForget,
StateMgmtSetting stateMgmtSettings) |
EventTableFactory |
EventTableIndexServiceImpl.createSorted(int indexedStreamNum,
EventType eventType,
String indexedProp,
EPTypeClass indexType,
EventPropertyValueGetter getter,
DataInputOutputSerde<Object> serde,
DataInputOutputSerde<Object> optionalValueSerde,
boolean isFireAndForget,
StateMgmtSetting stateMgmtSettings) |
EventTableFactory |
EventTableIndexServiceImpl.createSorted(int indexedStreamNum,
EventType eventType,
String indexedProp,
EPTypeClass indexType,
EventPropertyValueGetter getter,
DataInputOutputSerde<Object> serde,
DataInputOutputSerde<Object> optionalValueSerde,
boolean isFireAndForget,
StateMgmtSetting stateMgmtSettings) |
EventTableFactory |
EventTableIndexService.createSorted(int indexedStreamNum,
EventType eventType,
String indexedProp,
EPTypeClass indexType,
EventPropertyValueGetter getter,
DataInputOutputSerde<Object> serde,
DataInputOutputSerde<Object> optionalValueSerde,
boolean isFireAndForget,
StateMgmtSetting stateMgmtSettings) |
EventTableFactory |
EventTableIndexService.createSorted(int indexedStreamNum,
EventType eventType,
String indexedProp,
EPTypeClass indexType,
EventPropertyValueGetter getter,
DataInputOutputSerde<Object> serde,
DataInputOutputSerde<Object> optionalValueSerde,
boolean isFireAndForget,
StateMgmtSetting stateMgmtSettings) |
EventTableFactory |
EventTableIndexServiceImpl.createUnindexed(int indexedStreamNum,
EventType eventType,
DataInputOutputSerde<Object> optionalValueSerde,
boolean isFireAndForget,
StateMgmtSetting stateMgmtSettings) |
EventTableFactory |
EventTableIndexService.createUnindexed(int indexedStreamNum,
EventType eventType,
DataInputOutputSerde<Object> optionalValueSerde,
boolean isFireAndForget,
StateMgmtSetting stateMgmtSettings) |
Constructor and Description |
---|
PropertyCompositeEventTableFactoryFactory(int indexedStreamNum,
Integer subqueryNum,
boolean isFireAndForget,
String[] keyProps,
EPTypeClass[] keyTypes,
EventPropertyValueGetter keyGetter,
DataInputOutputSerde<Object> keySerde,
String[] rangeProps,
EPTypeClass[] rangeTypes,
EventPropertyValueGetter[] rangeGetters,
DataInputOutputSerde<Object>[] rangeKeySerdes) |
PropertyCompositeEventTableFactoryFactory(int indexedStreamNum,
Integer subqueryNum,
boolean isFireAndForget,
String[] keyProps,
EPTypeClass[] keyTypes,
EventPropertyValueGetter keyGetter,
DataInputOutputSerde<Object> keySerde,
String[] rangeProps,
EPTypeClass[] rangeTypes,
EventPropertyValueGetter[] rangeGetters,
DataInputOutputSerde<Object>[] rangeKeySerdes) |
Constructor and Description |
---|
PropertyHashedFactoryFactory(int indexedStreamNum,
Integer subqueryNum,
boolean isFireAndForget,
String[] indexProps,
boolean unique,
EventPropertyValueGetter valueGetter,
MultiKeyFromObjectArray transformFireAndForget,
DataInputOutputSerde<Object> keySerde,
StateMgmtSetting stateMgmtSettings) |
Modifier and Type | Field and Description |
---|---|
protected DataInputOutputSerde<Object>[] |
PropertyHashedArrayFactoryFactory.propertySerdes |
Constructor and Description |
---|
PropertyHashedArrayFactoryFactory(int streamNum,
String[] propertyNames,
EPTypeClass[] propertyTypes,
DataInputOutputSerde<Object>[] propertySerdes,
boolean unique,
EventPropertyValueGetter[] propertyGetters,
boolean isFireAndForget,
StateMgmtSetting stateMgmtSettings) |
Constructor and Description |
---|
PropertySortedFactoryFactory(int indexedStreamNum,
Integer subqueryNum,
boolean isFireAndForget,
String indexProp,
EPTypeClass indexType,
EventPropertyValueGetter valueGetter,
DataInputOutputSerde<Object> indexSerde,
StateMgmtSetting stateMgmtSettings) |
Modifier and Type | Method and Description |
---|---|
DataInputOutputSerde<Object> |
QueryPlanIndexItem.getHashKeySerde() |
DataInputOutputSerde<Object>[] |
QueryPlanIndexItem.getRangeKeySerdes() |
Modifier and Type | Method and Description |
---|---|
void |
EventTableIndexRepository.addExplicitIndex(String explicitIndexName,
String explicitIndexModuleName,
QueryPlanIndexItem desc,
EventType eventType,
Iterable<EventBean> dataWindowContents,
AgentInstanceContext agentInstanceContext,
DataInputOutputSerde<Object> optionalSerde) |
Pair<IndexMultiKey,EventTableAndNamePair> |
EventTableIndexRepository.addExplicitIndexOrReuse(QueryPlanIndexItem desc,
Iterable<EventBean> prefilledEvents,
EventType indexedType,
String indexName,
String indexModuleName,
AgentInstanceContext agentInstanceContext,
DataInputOutputSerde<Object> optionalValueSerde) |
void |
EventTableIndexRepository.validateAddExplicitIndex(String explicitIndexName,
String explicitIndexModuleName,
QueryPlanIndexItem explicitIndexDesc,
EventType eventType,
Iterable<EventBean> dataWindowContents,
AgentInstanceContext agentInstanceContext,
boolean allowIndexExists,
DataInputOutputSerde<Object> optionalValueSerde) |
Modifier and Type | Method and Description |
---|---|
DataInputOutputSerde<Object> |
EvalEveryDistinctFactoryNode.getDistinctSerde() |
Modifier and Type | Method and Description |
---|---|
void |
EvalEveryDistinctFactoryNode.setDistinctSerde(DataInputOutputSerde<Object> distinctSerde) |
Modifier and Type | Field and Description |
---|---|
protected DataInputOutputSerde<Object> |
RowRecogNFAViewFactory.partitionKeySerde |
Modifier and Type | Method and Description |
---|---|
DataInputOutputSerde<Object> |
RowRecogDesc.getPartitionEvalSerde() |
DataInputOutputSerde<Object> |
RowRecogNFAViewFactory.getPartitionKeySerde() |
Modifier and Type | Method and Description |
---|---|
void |
RowRecogDesc.setPartitionEvalSerde(DataInputOutputSerde<Object> partitionEvalSerde) |
Modifier and Type | Field and Description |
---|---|
protected DataInputOutputSerde<Object> |
TableBase.primaryKeySerde |
Modifier and Type | Method and Description |
---|---|
DataInputOutputSerde |
TableSerdes.getAggregations() |
DataInputOutputSerde[] |
TableSerdes.getColumnStartingZero() |
DataInputOutputSerde<Object> |
TableBase.getPrimaryKeySerde() |
DataInputOutputSerde<Object> |
Table.getPrimaryKeySerde() |
Modifier and Type | Method and Description |
---|---|
TableSerdes |
TableManagementServiceImpl.getTableSerdes(Table table,
DataInputOutputSerde aggregationSerde,
StatementContext statementContext) |
void |
TableBase.setPrimaryKeySerde(DataInputOutputSerde<Object> primaryKeySerde) |
void |
Table.setPrimaryKeySerde(DataInputOutputSerde<Object> primaryKeySerde) |
Constructor and Description |
---|
TableSerdes(DataInputOutputSerde[] column,
DataInputOutputSerde aggregations) |
TableSerdes(DataInputOutputSerde[] column,
DataInputOutputSerde aggregations) |
Modifier and Type | Method and Description |
---|---|
void |
VariableStateNonConstHandler.addVariable(String deploymentId,
String variableName,
Variable variable,
DataInputOutputSerde serde) |
void |
VariableManagementServiceImpl.addVariable(String deploymentId,
VariableMetaData metaData,
String optionalDeploymentIdContext,
DataInputOutputSerde<Object> optionalSerde) |
void |
VariableManagementService.addVariable(String deploymentId,
VariableMetaData metaData,
String optionalDeploymentIdContext,
DataInputOutputSerde<Object> optionalSerde) |
Modifier and Type | Class and Description |
---|---|
class |
DIOJsonAnyValueSerde |
class |
DIOJsonArraySerde |
class |
DIOJsonObjectSerde |
Modifier and Type | Method and Description |
---|---|
DataInputOutputSerde<Object> |
EventTypeCollectedSerde.getUnderlyingSerde() |
Modifier and Type | Method and Description |
---|---|
void |
EventTypeCollectorImpl.registerSerde(EventTypeMetadata metadata,
DataInputOutputSerde<Object> underlyingSerde,
EPTypeClass underlyingClass) |
void |
EventTypeCollector.registerSerde(EventTypeMetadata metadata,
DataInputOutputSerde<Object> underlyingSerde,
EPTypeClass underlyingClass) |
Constructor and Description |
---|
EventTypeCollectedSerde(EventTypeMetadata metadata,
DataInputOutputSerde<Object> underlyingSerde,
EPTypeClass underlying) |
Modifier and Type | Method and Description |
---|---|
DataInputOutputSerde |
BaseXMLEventType.getUnderlyingBindingDIO() |
Modifier and Type | Method and Description |
---|---|
void |
BaseXMLEventType.setUnderlyingBindingDIO(DataInputOutputSerde<Object> underlyingSerde) |
Modifier and Type | Method and Description |
---|---|
protected static DataInputOutputSerde |
VMBasicBuiltinSerdeFactory.getSerde(Class cls)
Returns the serde for the given Java built-in type.
|
static DataInputOutputSerde |
VMExtendedBuiltinSerdeFactory.getSerde(EPTypeClass typeClass) |
static DataInputOutputSerde |
VMExtendedBuiltinSerdeFactory.getSerde(String classNamePretty) |
static DataInputOutputSerde |
VMBasicBuiltinSerdeFactory.getSerde(String classNamePretty) |
Modifier and Type | Method and Description |
---|---|
DataInputOutputSerde<Object> |
EventSerdeFactoryDefault.objectArrayMayNullNull(DataInputOutputSerde[] serdes) |
DataInputOutputSerde<Object> |
EventSerdeFactory.objectArrayMayNullNull(DataInputOutputSerde[] serdes) |
DIOSerdeTreeMapEventsMayDeque |
EventSerdeFactoryDefault.treeMapEventsMayDeque(DataInputOutputSerde[] criteriaSerdes,
EventType eventType) |
DIOSerdeTreeMapEventsMayDeque |
EventSerdeFactory.treeMapEventsMayDeque(DataInputOutputSerde[] criteriaSerdes,
EventType eventType) |
Modifier and Type | Class and Description |
---|---|
class |
DIOMapPropertySerde |
class |
DIORefCountedSet |
class |
DIOSortedRefCountedSet |
Constructor and Description |
---|
DIOMapPropertySerde(String[] keys,
DataInputOutputSerde[] serdes) |
DIORefCountedSet(DataInputOutputSerde inner) |
DIOSortedRefCountedSet(DataInputOutputSerde inner) |
Constructor and Description |
---|
DIONullableObjectArraySerde(Class componentType,
DataInputOutputSerde componentBinding) |
DIOSetSerde(DataInputOutputSerde inner) |
Modifier and Type | Interface and Description |
---|---|
interface |
DIOMultiKeyArraySerde<E> |
Modifier and Type | Class and Description |
---|---|
class |
DIOMultiKeyArrayBooleanSerde |
class |
DIOMultiKeyArrayByteSerde |
class |
DIOMultiKeyArrayCharSerde |
class |
DIOMultiKeyArrayDoubleSerde |
class |
DIOMultiKeyArrayFloatSerde |
class |
DIOMultiKeyArrayIntSerde |
class |
DIOMultiKeyArrayLongSerde |
class |
DIOMultiKeyArrayObjectSerde |
class |
DIOMultiKeyArrayShortSerde |
Modifier and Type | Method and Description |
---|---|
DataInputOutputSerde[] |
StatViewAdditionalPropsEval.getAdditionalSerdes() |
Constructor and Description |
---|
StatViewAdditionalPropsEval(String[] additionalProps,
ExprEvaluator[] additionalEvals,
EPTypeClass[] additionalTypes,
DataInputOutputSerde[] additionalSerdes) |
Modifier and Type | Field and Description |
---|---|
protected DataInputOutputSerde<Object> |
FirstUniqueByPropertyViewFactory.keySerde |
Modifier and Type | Method and Description |
---|---|
void |
FirstUniqueByPropertyViewFactory.setKeySerde(DataInputOutputSerde<Object> keySerde) |
Modifier and Type | Field and Description |
---|---|
protected DataInputOutputSerde<Object> |
GroupByViewFactory.keySerde |
Modifier and Type | Method and Description |
---|---|
DataInputOutputSerde<Object> |
GroupByViewFactory.getKeySerde() |
Modifier and Type | Method and Description |
---|---|
void |
GroupByViewFactory.setKeySerde(DataInputOutputSerde<Object> keySerde) |
Modifier and Type | Field and Description |
---|---|
protected DataInputOutputSerde<Object> |
RankWindowViewFactory.keySerde |
protected DataInputOutputSerde<Object>[] |
RankWindowViewFactory.sortSerdes |
Modifier and Type | Method and Description |
---|---|
void |
RankWindowViewFactory.setKeySerde(DataInputOutputSerde<Object> keySerde) |
void |
RankWindowViewFactory.setSortSerdes(DataInputOutputSerde<Object>[] sortSerdes) |
Modifier and Type | Field and Description |
---|---|
protected DataInputOutputSerde<Object>[] |
SortWindowViewFactory.sortSerdes |
Modifier and Type | Method and Description |
---|---|
void |
SortWindowViewFactory.setSortSerdes(DataInputOutputSerde<Object>[] sortSerdes) |
Modifier and Type | Field and Description |
---|---|
protected DataInputOutputSerde<Object> |
UniqueByPropertyViewFactory.keySerde |
Modifier and Type | Method and Description |
---|---|
DataInputOutputSerde<Object> |
UniqueByPropertyViewFactory.getKeySerde() |
Modifier and Type | Method and Description |
---|---|
void |
UniqueByPropertyViewFactory.setKeySerde(DataInputOutputSerde<Object> keySerde) |
Copyright © 2005–2021. All rights reserved.