Modifier and Type | Method and Description |
---|---|
DataInputOutputSerdeForge |
SerdeProvisionParameterized.toForge() |
DataInputOutputSerdeForge |
SerdeProvisionByClass.toForge() |
DataInputOutputSerdeForge |
SerdeProvisionArrayOfNonPrimitive.toForge() |
abstract DataInputOutputSerdeForge |
SerdeProvision.toForge()
Convert to serde forge
|
Modifier and Type | Method and Description |
---|---|
DataInputOutputSerdeForge[] |
StateMgmtIndexDescComposite.getRangeSerdes() |
DataInputOutputSerdeForge |
StateMgmtIndexDescSorted.getSerde() |
DataInputOutputSerdeForge[] |
StateMgmtIndexDescInMulti.getSerdes() |
Constructor and Description |
---|
StateMgmtIndexDescComposite(String[] indexedProps,
MultiKeyClassRef multiKeyPlan,
String[] indexedRangeProps,
DataInputOutputSerdeForge[] rangeSerdes) |
StateMgmtIndexDescInMulti(String[] indexedProps,
DataInputOutputSerdeForge[] serdes) |
StateMgmtIndexDescSorted(String property,
DataInputOutputSerdeForge serde) |
Modifier and Type | Method and Description |
---|---|
DataInputOutputSerdeForge |
MultiKeyClassRefWSerde.getForge() |
DataInputOutputSerdeForge[] |
MultiKeyClassRefWSerde.getSerdeForges() |
DataInputOutputSerdeForge[] |
MultiKeyClassRefUUIDBased.getSerdeForges() |
DataInputOutputSerdeForge[] |
MultiKeyClassRefPredetermined.getSerdeForges() |
DataInputOutputSerdeForge[] |
MultiKeyClassRefEmpty.getSerdeForges() |
DataInputOutputSerdeForge[] |
MultiKeyClassRef.getSerdeForges() |
DataInputOutputSerdeForge[] |
MultiKeyClassRefUUIDBased.getSerdes() |
Constructor and Description |
---|
MultiKeyClassRefPredetermined(EPTypeClass clazzMK,
EPType[] mkTypes,
DataInputOutputSerdeForge serdeForge,
DIOMultiKeyArraySerde mkSerde) |
MultiKeyClassRefUUIDBased(EPType[] mkTypes,
DataInputOutputSerdeForge[] serdes) |
MultiKeyClassRefWSerde(DataInputOutputSerdeForge forge,
EPType[] types) |
StmtClassForgeableMultiKeySerde(String className,
CodegenPackageScope packageScope,
EPType[] types,
String classNameMK,
DataInputOutputSerdeForge[] forges) |
Modifier and Type | Method and Description |
---|---|
DataInputOutputSerdeForge[] |
ContextSpecKeyedItem.getLookupableSerdes() |
Modifier and Type | Method and Description |
---|---|
void |
ContextSpecKeyedItem.setLookupableSerdes(DataInputOutputSerdeForge[] lookupableSerdes) |
Constructor and Description |
---|
StmtClassForgeableAIFactoryProviderCreateVariable(String className,
CodegenPackageScope packageScope,
StatementAgentInstanceFactoryCreateVariableForge forge,
String variableName,
DataInputOutputSerdeForge serde) |
Modifier and Type | Method and Description |
---|---|
void |
ContextCompileTimeFabricFilter.accept(FilterOperator operator,
String expression,
DataInputOutputSerdeForge forge) |
Modifier and Type | Field and Description |
---|---|
protected DataInputOutputSerdeForge |
AggregationForgeFactoryFirstLastUnbound.serde |
Constructor and Description |
---|
AggregationForgeFactoryFirstLastUnbound(ExprAggMultiFunctionLinearAccessNode parent,
EPTypeClass resultType,
boolean hasFilter,
DataInputOutputSerdeForge serde) |
Modifier and Type | Method and Description |
---|---|
DataInputOutputSerdeForge[] |
SortedAggregationStateDesc.getCriteriaSerdes() |
Constructor and Description |
---|
SortedAggregationStateDesc(boolean max,
ClasspathImportServiceCompileTime classpathImportService,
ExprNode[] criteria,
EPType[] criteriaTypes,
DataInputOutputSerdeForge[] criteriaSerdes,
boolean[] sortDescending,
boolean ever,
int streamNum,
ExprAggMultiFunctionSortedMinMaxByNode parent,
ExprForge optionalFilter,
EventType streamEventType) |
Modifier and Type | Field and Description |
---|---|
protected DataInputOutputSerdeForge |
AggregationForgeFactoryAvedev.distinctSerde |
Constructor and Description |
---|
AggregationForgeFactoryAvedev(ExprAvedevNode parent,
EPTypeClass aggregatedValueType,
DataInputOutputSerdeForge distinctSerde,
ExprNode[] positionalParameters) |
AggregatorAvedev(EPTypeClass optionalDistinctValueType,
DataInputOutputSerdeForge optionalDistinctSerde,
boolean hasFilter,
ExprNode optionalFilter) |
Modifier and Type | Field and Description |
---|---|
protected DataInputOutputSerdeForge |
AggregationForgeFactoryAvg.distinctSerde |
Constructor and Description |
---|
AggregationForgeFactoryAvg(ExprAvgNode parent,
EPTypeClass childType,
DataInputOutputSerdeForge distinctSerde,
MathContext optionalMathContext) |
AggregatorAvgBig(EPTypeClass optionalDistinctValueType,
DataInputOutputSerdeForge optionalDistinctSerde,
boolean hasFilter,
ExprNode optionalFilter,
AggregationForgeFactoryAvg factory) |
AggregatorAvgNonBig(EPTypeClass optionalDistinctValueType,
DataInputOutputSerdeForge optionalDistinctSerde,
boolean hasFilter,
ExprNode optionalFilter,
EPTypeClass sumType) |
Modifier and Type | Field and Description |
---|---|
protected DataInputOutputSerdeForge |
AggregatorMethodWDistinctWFilterBase.optionalDistinctSerde |
Constructor and Description |
---|
AggregatorMethodWDistinctWFilterBase(EPType optionalDistinctValueType,
DataInputOutputSerdeForge optionalDistinctSerde,
boolean hasFilter,
ExprNode optionalFilter) |
AggregatorMethodWDistinctWFilterWValueBase(EPType optionalDistinctValueType,
DataInputOutputSerdeForge optionalDistinctSerde,
boolean hasFilter,
ExprNode optionalFilter) |
Modifier and Type | Field and Description |
---|---|
protected DataInputOutputSerdeForge |
AggregationForgeFactoryCountEver.distinctSerde |
protected DataInputOutputSerdeForge |
AggregationForgeFactoryCount.distinctValueSerde |
Constructor and Description |
---|
AggregationForgeFactoryCount(ExprCountNode parent,
boolean ignoreNulls,
EPType countedValueType,
DataInputOutputSerdeForge distinctValueSerde) |
AggregationForgeFactoryCountEver(ExprCountEverNode parent,
boolean ignoreNulls,
EPType childType,
DataInputOutputSerdeForge distinctSerde) |
AggregatorCount(EPType optionalDistinctValueType,
DataInputOutputSerdeForge optionalDistinctSerde,
boolean hasFilter,
ExprNode optionalFilter,
boolean isEver) |
Modifier and Type | Field and Description |
---|---|
protected DataInputOutputSerdeForge |
AggregationForgeFactoryFirstLastEver.serde |
Constructor and Description |
---|
AggregationForgeFactoryFirstLastEver(ExprFirstLastEverNode parent,
EPTypeClass childType,
DataInputOutputSerdeForge serde) |
AggregatorFirstEver(EPTypeClass optionalDistinctValueType,
DataInputOutputSerdeForge optionalDistinctSerde,
boolean hasFilter,
ExprNode optionalFilter,
EPTypeClass childType,
DataInputOutputSerdeForge serde) |
AggregatorLastEver(EPTypeClass optionalDistinctValueType,
DataInputOutputSerdeForge optionalDistinctSerde,
boolean hasFilter,
ExprNode optionalFilter,
EPTypeClass childType,
DataInputOutputSerdeForge serde) |
Modifier and Type | Field and Description |
---|---|
protected DataInputOutputSerdeForge |
AggregationForgeFactoryMedian.distinctSerde |
Constructor and Description |
---|
AggregationForgeFactoryMedian(ExprMedianNode parent,
EPTypeClass aggregatedValueType,
DataInputOutputSerdeForge distinctSerde) |
AggregatorMedian(EPTypeClass optionalDistinctValueType,
DataInputOutputSerdeForge optionalDistinctSerde,
boolean hasFilter,
ExprNode optionalFilter) |
Modifier and Type | Field and Description |
---|---|
protected DataInputOutputSerdeForge |
AggregationForgeFactoryMinMax.distinctSerde |
protected DataInputOutputSerdeForge |
AggregationForgeFactoryMinMax.serde |
Constructor and Description |
---|
AggregationForgeFactoryMinMax(ExprMinMaxAggrNode parent,
EPTypeClass type,
boolean hasDataWindows,
DataInputOutputSerdeForge serde,
DataInputOutputSerdeForge distinctSerde) |
AggregatorMinMax(AggregationForgeFactoryMinMax factory,
EPTypeClass optionalDistinctValueType,
DataInputOutputSerdeForge optionalDistinctSerde,
boolean hasFilter,
ExprNode optionalFilter) |
AggregatorMinMaxEver(AggregationForgeFactoryMinMax factory,
EPTypeClass optionalDistinctValueType,
DataInputOutputSerdeForge optionalDistinctSerde,
boolean hasFilter,
ExprNode optionalFilter,
DataInputOutputSerdeForge serde) |
Modifier and Type | Field and Description |
---|---|
protected DataInputOutputSerdeForge |
AggregationForgeFactoryNth.distinctSerde |
protected DataInputOutputSerdeForge |
AggregationForgeFactoryNth.serde |
Constructor and Description |
---|
AggregationForgeFactoryNth(ExprNthAggNode parent,
EPTypeClass childType,
DataInputOutputSerdeForge serde,
DataInputOutputSerdeForge distinctSerde,
int size) |
AggregatorNth(AggregationForgeFactoryNth factory,
EPTypeClass optionalDistinctValueType,
DataInputOutputSerdeForge optionalDistinctSerde,
boolean hasFilter,
ExprNode optionalFilter) |
Modifier and Type | Method and Description |
---|---|
DataInputOutputSerdeForge |
AggregationForgeFactoryPlugin.getDistinctSerde() |
Constructor and Description |
---|
AggregationForgeFactoryPlugin(ExprPlugInAggNode parent,
AggregationFunctionForge aggregationFunctionForge,
AggregationFunctionMode mode,
EPType aggregatedValueType,
DataInputOutputSerdeForge distinctSerde) |
AggregatorPlugInManaged(EPType optionalDistinctValueType,
DataInputOutputSerdeForge optionalDistinctSerde,
boolean hasFilter,
ExprNode optionalFilter,
AggregationFunctionModeManaged mode) |
Constructor and Description |
---|
AggregatorRate(AggregationForgeFactoryRate factory,
EPTypeClass optionalDistinctValueType,
DataInputOutputSerdeForge optionalDistinctSerde,
boolean hasFilter,
ExprNode optionalFilter) |
AggregatorRateEver(AggregationForgeFactoryRate factory,
EPTypeClass optionalDistinctValueType,
DataInputOutputSerdeForge optionalDistinctSerde,
boolean hasFilter,
ExprNode optionalFilter) |
Modifier and Type | Field and Description |
---|---|
protected DataInputOutputSerdeForge |
AggregationForgeFactoryStddev.distinctSerde |
Constructor and Description |
---|
AggregationForgeFactoryStddev(ExprStddevNode parent,
EPTypeClass aggregatedValueType,
DataInputOutputSerdeForge distinctSerde) |
AggregatorStddev(EPTypeClass optionalDistinctValueType,
DataInputOutputSerdeForge optionalDistinctSerde,
boolean hasFilter,
ExprNode optionalFilter) |
Modifier and Type | Field and Description |
---|---|
protected DataInputOutputSerdeForge |
AggregationForgeFactorySum.distinctSerde |
Constructor and Description |
---|
AggregationForgeFactorySum(ExprSumNode parent,
EPTypeClass inputValueType,
DataInputOutputSerdeForge distinctSerde) |
AggregatorSumBase(EPTypeClass optionalDistinctValueType,
DataInputOutputSerdeForge optionalDistinctSerde,
boolean hasFilter,
ExprNode optionalFilter,
EPTypeClass sumType) |
AggregatorSumBig(EPTypeClass optionalDistinctValueType,
DataInputOutputSerdeForge optionalDistinctSerde,
boolean hasFilter,
ExprNode optionalFilter,
EPTypeClass sumType) |
AggregatorSumNonBig(EPTypeClass optionalDistinctValueType,
DataInputOutputSerdeForge optionalDistinctSerde,
boolean hasFilter,
ExprNode optionalFilter,
EPTypeClass sumType) |
Modifier and Type | Field and Description |
---|---|
protected DataInputOutputSerdeForge |
ExprFilterSpecLookupableForge.valueSerde |
Modifier and Type | Method and Description |
---|---|
DataInputOutputSerdeForge |
ExprFilterSpecLookupableForge.getValueSerde() |
Constructor and Description |
---|
ExprFilterSpecLookupableForge(String expression,
ExprEventEvaluatorForge optionalEventEvalForge,
ExprForge optionalExprForge,
EPTypeClass returnType,
boolean isNonPropertyGetter,
DataInputOutputSerdeForge valueSerde) |
Constructor and Description |
---|
PropertyCompositeEventTableFactoryFactoryForge(int indexedStreamNum,
Integer subqueryNum,
boolean isFireAndForget,
String[] optKeyProps,
EPTypeClass[] optKeyTypes,
MultiKeyClassRef hashMultikeyClasses,
String[] rangeProps,
EPTypeClass[] rangeTypes,
DataInputOutputSerdeForge[] rangeSerdes,
EventType eventType) |
Modifier and Type | Field and Description |
---|---|
protected DataInputOutputSerdeForge[] |
PropertyHashedArrayFactoryFactoryForge.serdes |
Constructor and Description |
---|
PropertyHashedArrayFactoryFactoryForge(int streamNum,
EventType eventType,
String[] propertyNames,
EPType[] propertyTypes,
DataInputOutputSerdeForge[] serdes,
boolean unique,
boolean isFireAndForget,
StateMgmtSetting stateMgmtSettings) |
Constructor and Description |
---|
PropertySortedFactoryFactoryForge(int indexedStreamNum,
Integer subqueryNum,
boolean isFireAndForget,
String indexedProp,
EventType eventType,
CoercionDesc coercionDesc,
DataInputOutputSerdeForge serde,
StateMgmtSetting stateMgmtSettings) |
Modifier and Type | Method and Description |
---|---|
void |
QueryPlanIndexItemForge.setRangeSerdes(DataInputOutputSerdeForge[] rangeSerdes) |
Modifier and Type | Method and Description |
---|---|
DataInputOutputSerdeForge[] |
TableAccessAnalysisResult.getInternalEventTypePropertySerdes() |
Constructor and Description |
---|
TableAccessAnalysisResult(Map<String,TableMetadataColumn> tableColumns,
ObjectArrayEventType internalEventType,
DataInputOutputSerdeForge[] internalEventTypePropertySerdes,
ObjectArrayEventType publicEventType,
TableMetadataColumnPairPlainCol[] colsPlain,
TableMetadataColumnPairAggMethod[] colsAggMethod,
TableMetadataColumnPairAggAccess[] colsAccess,
AggregationRowStateForgeDesc aggDesc,
String[] primaryKeyColumns,
EventPropertyGetterSPI[] primaryKeyGetters,
EPTypeClass[] primaryKeyTypes,
int[] primaryKeyColNums,
MultiKeyClassRef primaryKeyMultikeyClasses,
List<StmtClassForgeableFactory> additionalForgeables) |
Modifier and Type | Method and Description |
---|---|
void |
FabricTypeCollector.aggregatorNth(short serdeVersion,
int sizeOfBuf,
DataInputOutputSerdeForge serde) |
void |
FabricTypeCollector.refCountedSet(DataInputOutputSerdeForge serde) |
void |
FabricTypeCollector.serde(DataInputOutputSerdeForge serde) |
void |
FabricTypeCollector.serdeObjectArrayMayNullNull(DataInputOutputSerdeForge[] criteriaSerdes) |
void |
FabricTypeCollector.sortedRefCountedSet(DataInputOutputSerdeForge serde) |
void |
FabricTypeCollector.treeMapEventsMayDeque(DataInputOutputSerdeForge[] criteriaSerdes,
EventType eventType) |
Modifier and Type | Method and Description |
---|---|
DataInputOutputSerdeForge |
SerdeEventPropertyDesc.getForge() |
Modifier and Type | Method and Description |
---|---|
Map<EventType,DataInputOutputSerdeForge> |
SerdeEventTypeCompileTimeRegistryImpl.getEventTypes() |
Map<EventType,DataInputOutputSerdeForge> |
SerdeEventTypeCompileTimeRegistry.getEventTypes() |
Modifier and Type | Method and Description |
---|---|
void |
SerdeEventTypeCompileTimeRegistryImpl.addSerdeFor(EventType eventType,
DataInputOutputSerdeForge forge) |
void |
SerdeEventTypeCompileTimeRegistry.addSerdeFor(EventType eventType,
DataInputOutputSerdeForge forge) |
Constructor and Description |
---|
SerdeEventPropertyDesc(DataInputOutputSerdeForge forge,
Set<EventType> nestedTypes) |
StmtClassForgeableBaseNestableEventTypeSerde(String className,
CodegenPackageScope packageScope,
BaseNestableEventType eventType,
DataInputOutputSerdeForge[] forges) |
Modifier and Type | Class and Description |
---|---|
class |
DataInputOutputSerdeForgeEmptyCtor |
class |
DataInputOutputSerdeForgeEventSerde |
class |
DataInputOutputSerdeForgeMap |
class |
DataInputOutputSerdeForgeOfForges |
class |
DataInputOutputSerdeForgeParameterized |
class |
DataInputOutputSerdeForgeSingleton |
class |
DataInputOutputSerdeForgeSingletonBasicBuiltin |
class |
DataInputOutputSerdeForgeSingletonExtendedBuiltin |
class |
DataInputOutputSerdeForgeSingletonMKArray |
class |
DataInputOutputSerdeForgeSkip |
Modifier and Type | Method and Description |
---|---|
static CodegenExpression |
DataInputOutputSerdeForge.codegenArray(DataInputOutputSerdeForge[] serdes,
CodegenMethod method,
CodegenClassScope classScope,
CodegenExpression optionalEventTypeResolver) |
Constructor and Description |
---|
DataInputOutputSerdeForgeMap(String[] keys,
DataInputOutputSerdeForge[] valueSerdes) |
DataInputOutputSerdeForgeOfForges(String forgeClassName,
DataInputOutputSerdeForge[] forges) |
Constructor and Description |
---|
CodegenSharableSerdeClassArrayTyped(CodegenSharableSerdeClassArrayTyped.CodegenSharableSerdeName name,
EPType[] valueTypes,
DataInputOutputSerdeForge[] serdes,
CodegenClassScope classScope) |
CodegenSharableSerdeClassTyped(CodegenSharableSerdeClassTyped.CodegenSharableSerdeName name,
EPType valueType,
DataInputOutputSerdeForge forge,
CodegenClassScope classScope) |
Modifier and Type | Class and Description |
---|---|
class |
DIONullableObjectArraySerdeForge |
Modifier and Type | Method and Description |
---|---|
DataInputOutputSerdeForge |
DIONullableObjectArraySerdeForge.getComponentSerde() |
Constructor and Description |
---|
DIONullableObjectArraySerdeForge(EPTypeClass componentType,
DataInputOutputSerdeForge componentSerde) |
Modifier and Type | Method and Description |
---|---|
DataInputOutputSerdeForge[] |
StatViewAdditionalPropsForge.getAdditionalSerdes() |
Constructor and Description |
---|
StatViewAdditionalPropsForge(String[] additionalProps,
ExprNode[] additionalEvals,
EPTypeClass[] additionalTypes,
DataInputOutputSerdeForge[] additionalSerdes) |
Modifier and Type | Field and Description |
---|---|
protected DataInputOutputSerdeForge[] |
RankWindowViewForge.sortSerdes |
Modifier and Type | Method and Description |
---|---|
DataInputOutputSerdeForge[] |
RankWindowViewForge.getSortSerdes() |
Modifier and Type | Field and Description |
---|---|
protected DataInputOutputSerdeForge[] |
SortWindowViewForge.sortSerdes |
Modifier and Type | Method and Description |
---|---|
DataInputOutputSerdeForge[] |
SortWindowViewForge.getSortSerdes() |
Copyright © 2005–2021. All rights reserved.