| AbstractBeamCalcRel: |
| methods: |
| - beamComputeSelfCost |
| - estimateNodeStats |
| - getLimitCountOfSortRel |
| - isInputSortRelAndLimitOnly |
| AbstractSimulator: |
| methods: |
| - hasNext |
| - next |
| - remove |
| - results |
| - resultsPerWindow |
| ActionFactory: |
| methods: |
| - childPartitionsRecordAction |
| - dataChangeRecordAction |
| - detectNewPartitionsAction |
| - heartbeatRecordAction |
| - queryChangeStreamAction |
| AdaptableCollector: |
| methods: |
| - asContext |
| - collect |
| - getCounter |
| - getHistogram |
| - getTimer |
| - setProcessContext |
| AddFields: |
| methods: |
| - create |
| - expand |
| - field |
| - processElement |
| AddHarnessIdInterceptor: |
| methods: |
| - create |
| AddUuidsTransform: |
| methods: |
| - expand |
| AdvancingPhaser: {} |
| AfterAll: |
| methods: |
| - getWatermarkThatGuaranteesFiring |
| - of |
| - toString |
| AfterEach: |
| methods: |
| - getWatermarkThatGuaranteesFiring |
| - inOrder |
| - mayFinish |
| - toString |
| AfterFirst: |
| methods: |
| - getWatermarkThatGuaranteesFiring |
| - of |
| - toString |
| AfterPane: |
| methods: |
| - elementCountAtLeast |
| - equals |
| - getElementCount |
| - getWatermarkThatGuaranteesFiring |
| - hashCode |
| - isCompatible |
| - toString |
| AfterProcessingTime: |
| methods: |
| - alignedTo |
| - equals |
| - getTimestampTransforms |
| - getWatermarkThatGuaranteesFiring |
| - hashCode |
| - isCompatible |
| - pastFirstElementInPane |
| - plusDelayOf |
| - toString |
| AfterSynchronizedProcessingTime: |
| methods: |
| - equals |
| - getWatermarkThatGuaranteesFiring |
| - hashCode |
| - ofFirstElement |
| - toString |
| AfterWatermark: |
| methods: |
| - equals |
| - getContinuationTrigger |
| - getEarlyTrigger |
| - getLateTrigger |
| - getWatermarkThatGuaranteesFiring |
| - hashCode |
| - mayFinish |
| - pastEndOfWindow |
| - toString |
| - withEarlyFirings |
| - withLateFirings |
| AggregationCombineFnAdapter: |
| methods: |
| - addInput |
| - createAccumulator |
| - createCombineFn |
| - createCombineFnAnalyticsFunctions |
| - createConstantCombineFn |
| - extractOutput |
| - getAccumulatorCoder |
| - getDefaultOutputCoder |
| - mergeAccumulators |
| properties: |
| - EMPTY_ROW |
| - EMPTY_SCHEMA |
| - INSTANCE |
| AggregationQuery: |
| methods: |
| - apply |
| - create |
| - withMongoDbPipeline |
| AmqpIO: |
| methods: |
| - advance |
| - close |
| - createReader |
| - expand |
| - finalizeCheckpoint |
| - getCheckpointMark |
| - getCheckpointMarkCoder |
| - getCurrent |
| - getCurrentSource |
| - getCurrentTimestamp |
| - getOutputCoder |
| - getWatermark |
| - populateDisplayData |
| - processElement |
| - read |
| - setup |
| - split |
| - start |
| - teardown |
| - withAddresses |
| - withMaxNumRecords |
| - withMaxReadTime |
| - write |
| AmqpMessageCoder: |
| methods: |
| - decode |
| - encode |
| AmqpMessageCoderProviderRegistrar: |
| methods: |
| - getCoderProviders |
| AnnotateText: |
| methods: |
| - build |
| - expand |
| - features |
| - languageHint |
| - newBuilder |
| - processElement |
| - setFeatures |
| - setLanguageHint |
| ApiSurface: |
| methods: |
| - classesInPackage |
| - containsOnlyClassesMatching |
| - containsOnlyPackages |
| - describeTo |
| - empty |
| - getAnyExposurePath |
| - getExposedClasses |
| - getRootClasses |
| - includingClass |
| - includingPackage |
| - ofClass |
| - ofPackage |
| - pruningClass |
| - pruningClassName |
| - pruningPattern |
| - pruningPrefix |
| AppliedCombineFn: |
| methods: |
| - getAccumulatorCoder |
| - getFn |
| - getKvCoder |
| - getSideInputViews |
| - getWindowingStrategy |
| - withAccumulatorCoder |
| - withInputCoder |
| AppliedPTransform: |
| methods: |
| - getFullName |
| - getInputs |
| - getMainInputs |
| - getOutputs |
| - getPipeline |
| - getResourceHints |
| - getTransform |
| - of |
| ApproximateCountDistinct: |
| methods: |
| - build |
| - expand |
| - getMapping |
| - getPrecision |
| - getUdaf |
| - globally |
| - perKey |
| - populateDisplayData |
| - setMapping |
| - setPrecision |
| - toBuilder |
| - via |
| - withPercision |
| ApproximateDistinct: |
| methods: |
| - addInput |
| - apply |
| - create |
| - createAccumulator |
| - decode |
| - encode |
| - expand |
| - extractOutput |
| - globally |
| - isRegisterByteSizeObserverCheap |
| - mergeAccumulators |
| - of |
| - perKey |
| - populateDisplayData |
| - precisionForRelativeError |
| - processElement |
| - relativeErrorForPrecision |
| - withPrecision |
| - withSparsePrecision |
| - withSparseRepresentation |
| ApproximateQuantiles: |
| methods: |
| - addInput |
| - create |
| - createAccumulator |
| - decode |
| - empty |
| - encode |
| - equals |
| - extractOutput |
| - getAccumulatorCoder |
| - globally |
| - hasNext |
| - hashCode |
| - isEmpty |
| - mergeAccumulator |
| - next |
| - perKey |
| - populateDisplayData |
| - registerByteSizeObserver |
| - singleton |
| - sizedIterator |
| - toString |
| - verifyDeterministic |
| - withEpsilon |
| - withMaxInputSize |
| properties: |
| - DEFAULT_MAX_NUM_ELEMENTS |
| ApproximateUnique: |
| methods: |
| - add |
| - addInput |
| - createAccumulator |
| - equals |
| - expand |
| - extractOutput |
| - getAccumulatorCoder |
| - globally |
| - hashCode |
| - mergeAccumulators |
| - perKey |
| - populateDisplayData |
| ArrayAgg: |
| methods: |
| - addInput |
| - createAccumulator |
| - extractOutput |
| - mergeAccumulators |
| ArrowConversion: |
| methods: |
| - arrowSchemaFromInput |
| - close |
| - create |
| - get |
| - hasNext |
| - name |
| - next |
| - rowsFromRecordBatch |
| - rowsFromSerializedRecordBatch |
| - toBeamSchema |
| - visit |
| AsJsons: |
| methods: |
| - apply |
| - exceptionsInto |
| - exceptionsVia |
| - expand |
| - of |
| - withMapper |
| AssignEventTime: |
| methods: |
| - expand |
| - getEventTimeExtractor |
| - named |
| - of |
| - output |
| - using |
| AtomicCoder: |
| methods: |
| - equals |
| - getCoderArguments |
| - getComponents |
| - hashCode |
| - verifyDeterministic |
| AttributeValueCoder: |
| methods: |
| - decode |
| - encode |
| - of |
| AttributeValueCoderProviderRegistrar: |
| methods: |
| - getCoderProviders |
| Auction: |
| methods: |
| - decode |
| - encode |
| - equals |
| - hasAnnotation |
| - hashCode |
| - sizeInBytes |
| - structuralValue |
| - toString |
| - withAnnotation |
| - withoutAnnotation |
| properties: |
| - CODER |
| - category |
| - dateTime |
| - description |
| - expires |
| - extra |
| - id |
| - initialBid |
| - itemName |
| - reserve |
| - seller |
| AuctionBid: |
| methods: |
| - decode |
| - encode |
| - equals |
| - hashCode |
| - sizeInBytes |
| - structuralValue |
| - toString |
| properties: |
| - CODER |
| - auction |
| - bid |
| AuctionCount: |
| methods: |
| - decode |
| - encode |
| - equals |
| - hashCode |
| - sizeInBytes |
| - structuralValue |
| - toString |
| properties: |
| - CODER |
| - auction |
| - num |
| AuctionGenerator: |
| methods: |
| - lastBase0AuctionId |
| - nextAuction |
| - nextBase0AuctionId |
| AuctionOrBid: |
| methods: |
| - apply |
| AuctionPrice: |
| methods: |
| - decode |
| - encode |
| - equals |
| - hashCode |
| - sizeInBytes |
| - structuralValue |
| - toString |
| properties: |
| - CODER |
| - auction |
| - price |
| AutoValueSchema: |
| methods: |
| - fieldValueGetters |
| - fieldValueTypeInformations |
| - get |
| - schemaFor |
| - schemaTypeCreator |
| properties: |
| - INSTANCE |
| AutoValueUtils: |
| methods: |
| - appender |
| - getBaseAutoValueClass |
| - getBuilderCreator |
| - getConstructorCreator |
| - prepare |
| AvroCoder: |
| methods: |
| - check |
| - coderFor |
| - decode |
| - encode |
| - equals |
| - fromLong |
| - get |
| - getCoderProvider |
| - getConvertedType |
| - getEncodedTypeDescriptor |
| - getLogicalTypeName |
| - getSchema |
| - getType |
| - hashCode |
| - initialValue |
| - of |
| - toLong |
| - useReflectApi |
| - verifyDeterministic |
| AvroGenericCoder: |
| methods: |
| - of |
| AvroIO: |
| methods: |
| - apply |
| - constantDestinations |
| - expand |
| - flush |
| - from |
| - open |
| - parseAllGenericRecords |
| - parseFilesGenericRecords |
| - parseGenericRecords |
| - populateDisplayData |
| - read |
| - readAll |
| - readAllGenericRecords |
| - readFiles |
| - readFilesGenericRecords |
| - readGenericRecords |
| - sink |
| - sinkViaGenericRecords |
| - to |
| - toResource |
| - watchForNewFiles |
| - withBeamSchemas |
| - withCodec |
| - withCoder |
| - withDatumReaderFactory |
| - withDatumWriterFactory |
| - withEmptyMatchTreatment |
| - withFileExceptionHandler |
| - withFormatFunction |
| - withHintMatchesManyFiles |
| - withMatchConfiguration |
| - withMetadata |
| - withNoSpilling |
| - withNumShards |
| - withOutputFilenames |
| - withSchema |
| - withShardNameTemplate |
| - withSuffix |
| - withSyncInterval |
| - withTempDirectory |
| - withUsesReshuffle |
| - withWindowedWrites |
| - withoutSharding |
| - write |
| - writeCustomType |
| - writeCustomTypeToGenericRecords |
| - writeGenericRecords |
| AvroPayloadSerializerProvider: |
| methods: |
| - getSerializer |
| - identifier |
| AvroRecordSchema: |
| methods: |
| - fieldValueGetters |
| - fieldValueTypeInformations |
| - schemaFor |
| - schemaTypeCreator |
| AvroSchemaIOProvider: |
| methods: |
| - buildReader |
| - buildWriter |
| - configurationSchema |
| - expand |
| - from |
| - identifier |
| - isBounded |
| - requiresDataSchema |
| - schema |
| AvroSink: |
| methods: |
| - createWriteOperation |
| - createWriter |
| - getDynamicDestinations |
| - write |
| AvroSource: |
| methods: |
| - close |
| - createForSubrangeOfFile |
| - from |
| - getCodec |
| - getCurrentBlock |
| - getCurrentBlockOffset |
| - getCurrentBlockSize |
| - getCurrentRecord |
| - getCurrentSource |
| - getFractionOfBlockConsumed |
| - getOutputCoder |
| - getSchemaString |
| - getSplitPointsRemaining |
| - getSyncMarker |
| - length |
| - read |
| - readNextBlock |
| - readNextRecord |
| - seek |
| - tell |
| - validate |
| - withDatumReaderFactory |
| - withEmptyMatchTreatment |
| - withMinBundleSize |
| - withParseFn |
| - withSchema |
| AvroTableProvider: |
| methods: |
| - getSchemaIOProvider |
| - getTableType |
| AvroUtils: |
| methods: |
| - apply |
| - convertAvroFieldStrict |
| - createGetterConversions |
| - createSetterConversions |
| - createTypeConversion |
| - equals |
| - fromAvroType |
| - fromBeamFieldType |
| - get |
| - getAvroBytesToRowFunction |
| - getCreator |
| - getFieldTypes |
| - getFromRowFunction |
| - getGenericRecordToRowFunction |
| - getGetters |
| - getRowToAvroBytesFunction |
| - getRowToGenericRecordFunction |
| - getSchema |
| - getSize |
| - getToRowFunction |
| - hashCode |
| - schemaCoder |
| - toAvroField |
| - toAvroSchema |
| - toAvroType |
| - toBeamField |
| - toBeamRowStrict |
| - toBeamSchema |
| - toBeamType |
| - toGenericRecord |
| - withSize |
| properties: |
| - nullable |
| - type |
| AvroWriteRequest: |
| methods: |
| - getElement |
| - getSchema |
| AwsBuilderFactory: {} |
| AwsCoders: |
| methods: |
| - awsResponseMetadata |
| - decode |
| - encode |
| - of |
| - responseMetadata |
| - sdkHttpMetadata |
| - sdkHttpMetadataWithoutHeaders |
| - sdkHttpResponse |
| - sdkHttpResponseWithoutHeaders |
| - verifyDeterministic |
| AwsModule: |
| methods: |
| - canCreateUsingDefault |
| - createUsingDefault |
| - deserialize |
| - deserializeWithType |
| - serialize |
| - serializeWithType |
| - setupModule |
| properties: |
| - CLIENT_EXECUTION_TIMEOUT |
| - CONNECTION_MAX_IDLE_TIME |
| - CONNECTION_TIMEOUT |
| - CONNECTION_TIME_TO_LIVE |
| - MAX_CONNECTIONS |
| - PROXY_HOST |
| - PROXY_PASSWORD |
| - PROXY_PORT |
| - PROXY_USERNAME |
| - REQUEST_TIMEOUT |
| - SOCKET_TIMEOUT |
| AwsPipelineOptionsRegistrar: |
| methods: |
| - getPipelineOptions |
| AwsSchemaProvider: |
| methods: |
| - apply |
| - create |
| - equals |
| - fieldValueGetters |
| - fieldValueTypeInformations |
| - fromRowFunction |
| - hashCode |
| - schemaFor |
| - schemaTypeCreator |
| AwsSchemaRegistrar: |
| methods: |
| - getSchemaProviders |
| AwsSerializableUtils: |
| methods: |
| - deserialize |
| - deserializeAwsCredentialsProvider |
| - serialize |
| - serializeAwsCredentialsProvider |
| AwsTypes: {} |
| AzureBlobStoreFileSystemRegistrar: |
| methods: |
| - fromOptions |
| AzureModule: |
| methods: |
| - deserialize |
| - deserializeWithType |
| - serialize |
| - serializeWithType |
| AzurePipelineOptionsRegistrar: |
| methods: |
| - getPipelineOptions |
| BackOffAdapter: |
| methods: |
| - nextBackOffMillis |
| - reset |
| - toGcpBackOff |
| BackOffUtils: |
| methods: |
| - next |
| BagUserState: |
| methods: |
| - append |
| - asyncClose |
| - clear |
| - get |
| BaseBeamTable: |
| methods: |
| - buildIOReader |
| - constructFilter |
| - getTableStatistics |
| - supportsProjects |
| BasicDynamoDBProvider: |
| methods: |
| - createDynamoDB |
| BasicDynamoDbClientProvider: |
| methods: |
| - equals |
| - getDynamoDbClient |
| - hashCode |
| BatchContextImpl: |
| methods: |
| - addProperties |
| - addTags |
| - asMap |
| - createDataset |
| - datasetExists |
| - discardDataset |
| - get |
| - getArguments |
| - getDataset |
| - getFailureCollector |
| - getInputFormatProvider |
| - getInputSchema |
| - getInputSchemas |
| - getLogicalStartTime |
| - getMetadata |
| - getMetrics |
| - getNamespace |
| - getOutputFormatProvider |
| - getOutputPortSchemas |
| - getOutputSchema |
| - getPipelineName |
| - getPluginProperties |
| - getServiceURL |
| - getStageName |
| - has |
| - iterator |
| - loadPluginClass |
| - newPluginInstance |
| - provide |
| - record |
| - releaseDataset |
| - removeMetadata |
| - removeProperties |
| - removeTags |
| - set |
| properties: |
| - DEFAULT_SCHEMA_FIELD_NAME |
| - DEFAULT_SCHEMA_RECORD_NAME |
| BatchSinkContextImpl: |
| methods: |
| - addOutput |
| - isPreviewEnabled |
| BatchSourceContextImpl: |
| methods: |
| - getMaxPreviewRecords |
| - isPreviewEnabled |
| - setInput |
| BeamAccumulatorProvider: |
| methods: |
| - add |
| - create |
| - get |
| - getCounter |
| - getFactory |
| - getHistogram |
| - getName |
| - getNamespace |
| - getTimer |
| - increment |
| BeamAggregateProjectMergeRule: |
| methods: |
| - onMatch |
| properties: |
| - INSTANCE |
| BeamAggregationRel: |
| methods: |
| - beamComputeSelfCost |
| - buildPTransform |
| - copy |
| - estimateNodeStats |
| - expand |
| - explainTerms |
| - processElement |
| BeamAggregationRule: |
| methods: |
| - onMatch |
| properties: |
| - INSTANCE |
| BeamBasicAggregationRule: |
| methods: |
| - onMatch |
| properties: |
| - INSTANCE |
| BeamBigQuerySqlDialect: |
| methods: |
| - quoteIdentifier |
| - unparseCall |
| - unparseDateTimeLiteral |
| - unparseSqlIntervalLiteral |
| properties: |
| - DEFAULT |
| - DEFAULT_CONTEXT |
| - DOUBLE_NAN_WRAPPER |
| - DOUBLE_NEGATIVE_INF_WRAPPER |
| - DOUBLE_POSITIVE_INF_WRAPPER |
| - IN_ARRAY_OPERATOR |
| - NUMERIC_LITERAL_WRAPPER |
| BeamBuiltinAggregations: |
| methods: |
| - addInput |
| - apply |
| - create |
| - createAccumulator |
| - createBitXOr |
| - extractOutput |
| - getAccumulatorCoder |
| - identity |
| - mergeAccumulators |
| - toBigDecimal |
| properties: |
| - BUILTIN_AGGREGATOR_FACTORIES |
| BeamBuiltinAnalyticFunctions: |
| methods: |
| - addInput |
| - create |
| - createAccumulator |
| - extractOutput |
| - mergeAccumulators |
| - navigationFirstValue |
| - navigationLastValue |
| - numberingDenseRank |
| - numberingPercentRank |
| - numberingRank |
| - numberingRowNumber |
| properties: |
| - BUILTIN_ANALYTIC_FACTORIES |
| BeamBuiltinFunctionProvider: |
| methods: |
| - getBuiltinMethods |
| BeamBuiltinMethods: |
| properties: |
| - CHAR_LENGTH_METHOD |
| - CONCAT_METHOD |
| - DATE_METHOD |
| - ENDS_WITH_METHOD |
| - LIKE_METHOD |
| - LTRIM_METHOD |
| - REPLACE_METHOD |
| - REVERSE_METHOD |
| - RTRIM_METHOD |
| - STARTS_WITH_METHOD |
| - SUBSTR_METHOD |
| - TIMESTAMP_METHOD |
| - TRIM_METHOD |
| BeamCalcMergeRule: |
| methods: |
| - onMatch |
| properties: |
| - INSTANCE |
| BeamCalcRel: |
| methods: |
| - buildPTransform |
| - copy |
| - entrySet |
| - expand |
| - field |
| - get |
| - getQueryProvider |
| - getRootSchema |
| - getTypeFactory |
| - processElement |
| - setup |
| - size |
| BeamCalcRule: |
| methods: |
| - convert |
| - matches |
| properties: |
| - INSTANCE |
| BeamCalcSplittingRule: |
| methods: |
| - matches |
| - onMatch |
| BeamCalciteSchema: |
| methods: |
| - getExpression |
| - getFunctionNames |
| - getFunctions |
| - getPipelineOptions |
| - getSubSchema |
| - getSubSchemaNames |
| - getTable |
| - getTableNames |
| - getTableProvider |
| - getType |
| - getTypeNames |
| - isMutable |
| - removeAllPipelineOptions |
| - removePipelineOption |
| - setPipelineOption |
| - snapshot |
| BeamCalciteTable: |
| methods: |
| - asQueryable |
| - getModifiableCollection |
| - getRowType |
| - getStatistic |
| - of |
| - toModificationRel |
| - toRel |
| BeamCoGBKJoinRel: |
| methods: |
| - buildPTransform |
| - copy |
| - expand |
| BeamCoGBKJoinRule: |
| methods: |
| - matches |
| - onMatch |
| properties: |
| - INSTANCE |
| BeamCodegenUtils: |
| methods: |
| - toStringTimestamp |
| - toStringUTF8 |
| BeamCostModel: |
| methods: |
| - convertRelOptCost |
| - divideBy |
| - equals |
| - getCpu |
| - getCpuRate |
| - getIo |
| - getRows |
| - hashCode |
| - isEqWithEpsilon |
| - isInfinite |
| - isLe |
| - isLt |
| - makeCost |
| - makeHugeCost |
| - makeInfiniteCost |
| - makeTinyCost |
| - makeZeroCost |
| - minus |
| - multiplyBy |
| - plus |
| - toString |
| properties: |
| - FACTORY |
| BeamEnumerableConverter: |
| methods: |
| - computeSelfCost |
| - copy |
| - createPipelineOptions |
| - implement |
| - processElement |
| - startBundle |
| - toEnumerable |
| - toRowList |
| - visitValue |
| BeamEnumerableConverterRule: |
| methods: |
| - convert |
| properties: |
| - INSTANCE |
| BeamFnControlClient: |
| methods: |
| - delegateOnInstructionRequestType |
| - onCompleted |
| - onError |
| - onNext |
| - sendInstructionResponse |
| - waitForTermination |
| BeamFnDataGrpcClient: |
| methods: |
| - createOutboundAggregator |
| - registerReceiver |
| - unregisterReceiver |
| BeamFnDataGrpcMultiplexer: |
| methods: |
| - close |
| - getInboundObserver |
| - getOutboundObserver |
| - onCompleted |
| - onError |
| - onNext |
| - registerConsumer |
| - toString |
| BeamFnDataGrpcMultiplexer2: |
| methods: |
| - close |
| - getInboundObserver |
| - getOutboundObserver |
| - onCompleted |
| - onError |
| - onNext |
| - registerConsumer |
| - toString |
| - unregisterConsumer |
| BeamFnDataInboundObserver: |
| methods: |
| - accept |
| - awaitCompletion |
| - cancel |
| - complete |
| - fail |
| - forConsumer |
| - isDone |
| - runWhenComplete |
| BeamFnDataInboundObserver2: |
| methods: |
| - accept |
| - awaitCompletion |
| - close |
| - flush |
| - forConsumers |
| - getUnfinishedEndpoints |
| - multiplexElements |
| - reset |
| properties: |
| - INSTANCE |
| BeamFnDataOutboundAggregator: |
| methods: |
| - accept |
| - bufferedSize |
| - discard |
| - equals |
| - getByteCount |
| - getElementCount |
| - hashCode |
| - registerOutputDataLocation |
| - registerOutputTimersLocation |
| - resetStats |
| - sendElements |
| - sendOrCollectBufferedDataAndFinishOutboundStreams |
| - start |
| - toByteStringAndResetBuffer |
| - toString |
| properties: |
| - DATA_BUFFER_SIZE_LIMIT |
| - DATA_BUFFER_TIME_LIMIT_MS |
| - DEFAULT_BUFFER_LIMIT_BYTES |
| - DEFAULT_BUFFER_LIMIT_TIME_MS |
| BeamFnDataOutboundObserver: |
| methods: |
| - accept |
| - close |
| - flush |
| BeamFnDataReadRunner: |
| methods: |
| - blockTillReadFinishes |
| - createRunnerForPTransform |
| - forwardElementToConsumer |
| - getCache |
| - getCurrentInstructionId |
| - getPTransformRunnerFactories |
| - getStateClient |
| - reset |
| - trySplit |
| - updateFinalMonitoringData |
| - updateIntermediateMonitoringData |
| BeamFnDataWriteRunner: |
| methods: |
| - createRunnerForPTransform |
| - getCache |
| - getCurrentInstructionId |
| - getPTransformRunnerFactories |
| - getStateClient |
| BeamFnLoggingClient: |
| methods: |
| - beforeStart |
| - close |
| - flush |
| - onCompleted |
| - onError |
| - onNext |
| - publish |
| - run |
| - setProcessBundleHandler |
| - toString |
| BeamFnLoggingClientBenchmark: |
| methods: |
| - logging |
| - onCompleted |
| - onError |
| - onNext |
| - tearDown |
| - testLogging |
| - testLoggingWithAllOptionalParameters |
| - testSkippedLogging |
| properties: |
| - loggingClient |
| - loggingService |
| - server |
| BeamFnLoggingMDC: |
| methods: |
| - getInstructionId |
| - setInstructionId |
| BeamFnStateGrpcClientCache: |
| methods: |
| - forApiServiceDescriptor |
| - handle |
| - onCompleted |
| - onError |
| - onNext |
| BeamFnStatusClient: |
| methods: |
| - close |
| - equals |
| - getInstruction |
| - getTimeSinceTransition |
| - getTrackedThreadName |
| - hashCode |
| - onCompleted |
| - onError |
| - onNext |
| BeamIOPushDownRule: |
| methods: |
| - onMatch |
| properties: |
| - INSTANCE |
| BeamIOSinkRel: |
| methods: |
| - beamComputeSelfCost |
| - buildPTransform |
| - copy |
| - estimateNodeStats |
| - expand |
| - flattenRel |
| - getPipelineOptions |
| - register |
| BeamIOSinkRule: |
| methods: |
| - convert |
| properties: |
| - INSTANCE |
| BeamIOSourceRel: |
| methods: |
| - beamComputeSelfCost |
| - buildPTransform |
| - computeSelfCost |
| - createPushDownRel |
| - estimateNodeStats |
| - estimateRowCount |
| - expand |
| - getBeamSqlTable |
| - getPipelineOptions |
| - isBounded |
| properties: |
| - CONSTANT_WINDOW_SIZE |
| BeamIntersectRel: |
| methods: |
| - beamComputeSelfCost |
| - buildPTransform |
| - copy |
| - estimateNodeStats |
| BeamIntersectRule: |
| methods: |
| - convert |
| properties: |
| - INSTANCE |
| BeamJavaTypeFactory: |
| methods: |
| - getJavaClass |
| properties: |
| - INSTANCE |
| BeamJavaUdfCalcRule: |
| properties: |
| - INSTANCE |
| BeamJoinAssociateRule: |
| methods: |
| - onMatch |
| properties: |
| - INSTANCE |
| BeamJoinPushThroughJoinRule: |
| methods: |
| - onMatch |
| properties: |
| - LEFT |
| - RIGHT |
| BeamJoinRel: |
| methods: |
| - beamComputeSelfCost |
| - containsSeekableInput |
| - estimateNodeStats |
| - getBoundednessOfRelNode |
| - getPCollectionInputs |
| - isJoinLegal |
| - seekable |
| BeamJoinTransforms: |
| methods: |
| - expand |
| - getJoinColumns |
| - processElement |
| - setup |
| - teardown |
| BeamKafkaCSVTable: |
| methods: |
| - expand |
| - processElement |
| BeamKafkaTable: |
| methods: |
| - buildIOReader |
| - buildIOWriter |
| - getBootstrapServers |
| - getTableStatistics |
| - getTopics |
| - isBounded |
| - updateConsumerProperties |
| BeamMatchRel: |
| methods: |
| - beamComputeSelfCost |
| - buildPTransform |
| - copy |
| - estimateNodeStats |
| - expand |
| - processElement |
| BeamMatchRule: |
| methods: |
| - convert |
| properties: |
| - INSTANCE |
| BeamMinusRel: |
| methods: |
| - beamComputeSelfCost |
| - buildPTransform |
| - copy |
| - estimateNodeStats |
| BeamMinusRule: |
| methods: |
| - convert |
| properties: |
| - INSTANCE |
| BeamPCollectionTable: |
| methods: |
| - buildIOReader |
| - buildIOWriter |
| - isBounded |
| BeamPushDownIOSourceRel: |
| methods: |
| - beamComputeSelfCost |
| - buildPTransform |
| - expand |
| - explainTerms |
| BeamRelDataTypeSystem: |
| methods: |
| - getDefaultPrecision |
| - getMaxNumericPrecision |
| - getMaxNumericScale |
| - getMaxPrecision |
| - shouldConvertRaggedUnionTypesToVarying |
| properties: |
| - INSTANCE |
| BeamRelMetadataQuery: |
| methods: |
| - getNodeStats |
| - instance |
| BeamRowToBigtableMutation: |
| methods: |
| - apply |
| - expand |
| BeamRowToStorageApiProto: |
| methods: |
| - messageFromBeamRow |
| BeamRuleSets: |
| methods: |
| - getRuleSets |
| BeamSetOperatorRelBase: |
| methods: |
| - expand |
| BeamSetOperatorsTransforms: |
| methods: |
| - apply |
| - processElement |
| BeamSideInputJoinRel: |
| methods: |
| - buildPTransform |
| - copy |
| - expand |
| - sideInputJoin |
| BeamSideInputJoinRule: |
| methods: |
| - matches |
| - onMatch |
| properties: |
| - INSTANCE |
| BeamSideInputLookupJoinRel: |
| methods: |
| - buildPTransform |
| - copy |
| - expand |
| BeamSideInputLookupJoinRule: |
| methods: |
| - convert |
| - matches |
| properties: |
| - INSTANCE |
| BeamSortRel: |
| methods: |
| - beamComputeSelfCost |
| - buildPTransform |
| - compare |
| - copy |
| - estimateNodeStats |
| - expand |
| - getCount |
| - isLimitOnly |
| - processElement |
| BeamSortRule: |
| methods: |
| - convert |
| properties: |
| - INSTANCE |
| BeamSqlCli: |
| methods: |
| - execute |
| - explainQuery |
| - getMetaStore |
| - metaStore |
| BeamSqlDataCatalogExample: |
| methods: |
| - main |
| BeamSqlEnv: |
| methods: |
| - addSchema |
| - addUdaf |
| - addUdf |
| - autoLoadUserDefinedFunctions |
| - build |
| - builder |
| - executeDdl |
| - explain |
| - getContext |
| - getPipelineOptions |
| - inMemory |
| - isDdl |
| - parseQuery |
| - readOnly |
| - setCurrentSchema |
| - setPipelineOptions |
| - setQueryPlannerClassName |
| - setRuleSets |
| - withTableProvider |
| BeamSqlEnvRunner: |
| methods: |
| - runUsingBeamSqlEnv |
| BeamSqlLine: |
| methods: |
| - main |
| BeamSqlOutputToConsoleFn: |
| methods: |
| - processElement |
| BeamSqlParser: |
| methods: |
| - getDdlExecutor |
| - getParser |
| properties: |
| - DDL_EXECUTOR |
| - FACTORY |
| BeamSqlPipelineOptionsRegistrar: |
| methods: |
| - getPipelineOptions |
| BeamSqlRelUtils: |
| methods: |
| - explainLazily |
| - getBeamRelInput |
| - getErrorRowSchema |
| - getInput |
| - getNodeStats |
| - toPCollection |
| - toString |
| properties: |
| - ERROR |
| - ROW |
| BeamSqlUnparseContext: |
| methods: |
| - clone |
| - equals |
| - getNullParams |
| - hashCode |
| - implementor |
| - toSql |
| - unparse |
| BeamTableFunctionScanRel: |
| methods: |
| - beamComputeSelfCost |
| - buildPTransform |
| - copy |
| - estimateNodeStats |
| - expand |
| - processElement |
| BeamTableFunctionScanRule: |
| methods: |
| - convert |
| properties: |
| - INSTANCE |
| BeamTableStatistics: |
| methods: |
| - createBoundedTableStatistics |
| - createUnboundedTableStatistics |
| - getCollations |
| - getDistribution |
| - getKeys |
| - getRate |
| - getReferentialConstraints |
| - getRowCount |
| - isKey |
| - isUnknown |
| properties: |
| - BOUNDED_UNKNOWN |
| - UNBOUNDED_UNKNOWN |
| BeamTableUtils: |
| methods: |
| - autoCastField |
| - beamRow2CsvLine |
| - csvLines2BeamRows |
| BeamTpcds: |
| methods: |
| - main |
| BeamUncollectRel: |
| methods: |
| - beamComputeSelfCost |
| - buildPTransform |
| - copy |
| - estimateNodeStats |
| - expand |
| - process |
| BeamUncollectRule: |
| methods: |
| - convert |
| properties: |
| - INSTANCE |
| BeamUnionRel: |
| methods: |
| - beamComputeSelfCost |
| - buildPTransform |
| - copy |
| - estimateNodeStats |
| BeamUnionRule: |
| methods: |
| - convert |
| properties: |
| - INSTANCE |
| BeamUnnestRel: |
| methods: |
| - beamComputeSelfCost |
| - buildPTransform |
| - copy |
| - estimateNodeStats |
| - expand |
| - explainTerms |
| - process |
| BeamUnnestRule: |
| methods: |
| - onMatch |
| properties: |
| - INSTANCE |
| BeamValuesRel: |
| methods: |
| - beamComputeSelfCost |
| - buildPTransform |
| - estimateNodeStats |
| - expand |
| - getPipelineOptions |
| BeamValuesRule: |
| methods: |
| - convert |
| properties: |
| - INSTANCE |
| BeamWindowRel: |
| methods: |
| - beamComputeSelfCost |
| - buildPTransform |
| - copy |
| - estimateNodeStats |
| - expand |
| - processElement |
| BeamWindowRule: |
| methods: |
| - convert |
| properties: |
| - INSTANCE |
| BeamZetaSqlCalcMergeRule: |
| methods: |
| - onMatch |
| properties: |
| - INSTANCE |
| BeamZetaSqlCalcRel: |
| methods: |
| - buildPTransform |
| - copy |
| - expand |
| - finishBundle |
| - getAllowedTimestampSkew |
| - output |
| - outputWithTimestamp |
| - processElement |
| - setup |
| - startBundle |
| - teardown |
| BeamZetaSqlCalcRule: |
| properties: |
| - INSTANCE |
| BeamZetaSqlCalcSplittingRule: |
| properties: |
| - INSTANCE |
| BeamZetaSqlCatalog: |
| properties: |
| - PRE_DEFINED_WINDOW_FUNCTIONS |
| - USER_DEFINED_JAVA_AGGREGATE_FUNCTIONS |
| - USER_DEFINED_JAVA_SCALAR_FUNCTIONS |
| - USER_DEFINED_SQL_FUNCTIONS |
| - ZETASQL_FUNCTION_GROUP_NAME |
| BeamZetaSqlUncollectRel: |
| methods: |
| - beamComputeSelfCost |
| - buildPTransform |
| - copy |
| - estimateNodeStats |
| - expand |
| - process |
| BeamZetaSqlUncollectRule: |
| methods: |
| - convert |
| properties: |
| - INSTANCE |
| BeamZetaSqlUnnestRel: |
| methods: |
| - beamComputeSelfCost |
| - buildPTransform |
| - copy |
| - estimateNodeStats |
| - expand |
| - explainTerms |
| - process |
| BeamZetaSqlUnnestRule: |
| methods: |
| - onMatch |
| properties: |
| - INSTANCE |
| Bid: |
| methods: |
| - decode |
| - encode |
| - equals |
| - hasAnnotation |
| - hashCode |
| - sizeInBytes |
| - structuralValue |
| - toString |
| - verifyDeterministic |
| - withAnnotation |
| - withoutAnnotation |
| properties: |
| - ASCENDING_TIME_THEN_PRICE |
| - CODER |
| - PRICE_THEN_DESCENDING_TIME |
| - auction |
| - bidder |
| - dateTime |
| - extra |
| - price |
| BidGenerator: |
| methods: |
| - nextBid |
| BidsPerSession: |
| methods: |
| - decode |
| - encode |
| - equals |
| - hashCode |
| - sizeInBytes |
| - structuralValue |
| - toString |
| - verifyDeterministic |
| properties: |
| - CODER |
| BigDecimalCoder: |
| methods: |
| - consistentWithEquals |
| - decode |
| - encode |
| - isRegisterByteSizeObserverCheap |
| - of |
| - verifyDeterministic |
| BigDecimalConverter: |
| methods: |
| - forSqlType |
| BigEndianIntegerCoder: |
| methods: |
| - consistentWithEquals |
| - decode |
| - encode |
| - getEncodedTypeDescriptor |
| - isRegisterByteSizeObserverCheap |
| - of |
| - verifyDeterministic |
| BigEndianLongCoder: |
| methods: |
| - consistentWithEquals |
| - decode |
| - encode |
| - getEncodedTypeDescriptor |
| - isRegisterByteSizeObserverCheap |
| - of |
| - verifyDeterministic |
| BigEndianShortCoder: |
| methods: |
| - consistentWithEquals |
| - decode |
| - encode |
| - getEncodedTypeDescriptor |
| - isRegisterByteSizeObserverCheap |
| - of |
| - verifyDeterministic |
| BigIntegerCoder: |
| methods: |
| - consistentWithEquals |
| - decode |
| - encode |
| - isRegisterByteSizeObserverCheap |
| - of |
| - verifyDeterministic |
| BigQueryClient: |
| methods: |
| - create |
| - createTableIfNotExists |
| - insertAll |
| - insertRow |
| BigQueryCoderProviderRegistrar: |
| methods: |
| - getCoderProviders |
| BigQueryDirectReadSchemaTransformProvider: |
| methods: |
| - build |
| - buildTransform |
| - builder |
| - expand |
| - getQuery |
| - getRowRestriction |
| - getSelectedFields |
| - getTableSpec |
| - identifier |
| - inputCollectionNames |
| - outputCollectionNames |
| - setBigQueryServices |
| - setQuery |
| - setRowRestriction |
| - setSelectedFields |
| - setTableSpec |
| - validate |
| BigQueryDlqProvider: |
| methods: |
| - expand |
| - identifier |
| - newDlqTransform |
| BigQueryFilter: |
| methods: |
| - getNotSupported |
| - getSupported |
| - numSupported |
| - toString |
| BigQueryHelpers: |
| methods: |
| - apply |
| - fromJsonString |
| - getNumRows |
| - parseTableSpec |
| - parseTableUrn |
| - stripPartitionDecorator |
| - toJsonString |
| - toString |
| - toTableSpec |
| properties: |
| - jobId |
| - shouldRetry |
| BigQueryIO: |
| methods: |
| - actuateProjectionPushdown |
| - apply |
| - expand |
| - from |
| - fromQuery |
| - getTable |
| - getTableProvider |
| - ignoreInsertIds |
| - ignoreUnknownValues |
| - optimizedWrites |
| - populateDisplayData |
| - processElement |
| - read |
| - readTableRows |
| - readTableRowsWithSchema |
| - readWithDatumReader |
| - setSchema |
| - skipInvalidRows |
| - supportsProjectionPushdown |
| - to |
| - useAvroLogicalTypes |
| - useBeamSchema |
| - usingStandardSql |
| - validate |
| - withAutoSchemaUpdate |
| - withAutoSharding |
| - withAvroFormatFunction |
| - withAvroSchemaFactory |
| - withAvroWriter |
| - withBeamRowConverters |
| - withClustering |
| - withCoder |
| - withCreateDisposition |
| - withCustomGcsTempLocation |
| - withDeterministicRecordIdFn |
| - withExtendedErrorInfo |
| - withFailedInsertRetryPolicy |
| - withFormat |
| - withFormatFunction |
| - withFormatRecordOnFailureFunction |
| - withJsonSchema |
| - withJsonTimePartitioning |
| - withKmsKey |
| - withLoadJobProjectId |
| - withMaxBytesPerPartition |
| - withMaxFilesPerBundle |
| - withMethod |
| - withNumFileShards |
| - withNumStorageWriteApiStreams |
| - withQueryLocation |
| - withQueryPriority |
| - withQueryTempDataset |
| - withRowRestriction |
| - withSchema |
| - withSchemaFromView |
| - withSchemaUpdateOptions |
| - withSelectedFields |
| - withSuccessfulInsertsPropagation |
| - withTableDescription |
| - withTemplateCompatibility |
| - withTestServices |
| - withTimePartitioning |
| - withTriggeringFrequency |
| - withWriteDisposition |
| - withWriteTempDataset |
| - withoutResultFlattening |
| - withoutValidation |
| - write |
| - writeTableRows |
| properties: |
| - BIGQUERY_JOB_TEMPLATE |
| - INSTANCE |
| BigQueryInsertError: |
| methods: |
| - equals |
| - getError |
| - getRow |
| - getTable |
| - hashCode |
| BigQueryInsertErrorCoder: |
| methods: |
| - decode |
| - encode |
| - getEncodedTypeDescriptor |
| - of |
| - verifyDeterministic |
| BigQuerySchemaIOProvider: |
| methods: |
| - buildReader |
| - buildWriter |
| - configurationSchema |
| - expand |
| - from |
| - identifier |
| - isBounded |
| - requiresDataSchema |
| - schema |
| BigQuerySchemaRetrievalException: {} |
| BigQuerySchemaTransformReadConfiguration: |
| methods: |
| - build |
| - builder |
| - getQuery |
| - getQueryLocation |
| - getTableSpec |
| - getUseStandardSql |
| - setQuery |
| - setQueryLocation |
| - setTableSpec |
| - setUseStandardSql |
| BigQuerySchemaTransformReadProvider: |
| methods: |
| - buildTransform |
| - expand |
| - identifier |
| - inputCollectionNames |
| - outputCollectionNames |
| BigQuerySchemaTransformWriteConfiguration: |
| methods: |
| - build |
| - builder |
| - getCreateDisposition |
| - getTableSpec |
| - getWriteDisposition |
| - setCreateDisposition |
| - setTableSpec |
| - setWriteDisposition |
| BigQuerySchemaTransformWriteProvider: |
| methods: |
| - buildTransform |
| - expand |
| - identifier |
| - inputCollectionNames |
| - outputCollectionNames |
| - validate |
| BigQueryStorageApiInsertError: |
| methods: |
| - getErrorMessage |
| - getRow |
| - toString |
| BigQueryStorageApiInsertErrorCoder: |
| methods: |
| - decode |
| - encode |
| - of |
| BigQueryStorageTableSource: |
| methods: |
| - create |
| - getEstimatedSizeBytes |
| - populateDisplayData |
| BigQueryStorageWriteApiSchemaTransformProvider: |
| methods: |
| - build |
| - buildTransform |
| - builder |
| - expand |
| - getCreateDisposition |
| - getTable |
| - getTriggeringFrequencySeconds |
| - getUseAtLeastOnceSemantics |
| - getWriteDisposition |
| - identifier |
| - inputCollectionNames |
| - outputCollectionNames |
| - setBigQueryServices |
| - setCreateDisposition |
| - setTable |
| - setTriggeringFrequencySeconds |
| - setUseAtLeastOnceSemantics |
| - setWriteDisposition |
| - validate |
| BigQueryTableProvider: |
| methods: |
| - buildBeamSqlTable |
| - getTableType |
| BigQueryUtils: |
| methods: |
| - apply |
| - build |
| - builder |
| - convertAvroFormat |
| - convertGenericRecordToTableRow |
| - fromTableSchema |
| - getInferMaps |
| - getTruncateTimestamps |
| - hashSchemaDescriptorDeterministic |
| - readCallMetric |
| - setInferMaps |
| - setTruncateTimestamps |
| - tableRowFromBeamRow |
| - tableRowToBeamRow |
| - toBeamRow |
| - toGenericAvroSchema |
| - toTableReference |
| - toTableRow |
| - toTableSchema |
| - writeCallMetric |
| BigqueryClient: |
| methods: |
| - createNewDataset |
| - createNewTable |
| - deleteDataset |
| - deleteTable |
| - getClient |
| - getNewBigqueryClient |
| - getTableResource |
| - insertDataToTable |
| - queryUnflattened |
| - queryWithRetries |
| - queryWithRetriesUsingStandardSql |
| BigqueryMatcher: |
| methods: |
| - create |
| - createQuery |
| - createQueryUsingStandardSql |
| - describeMismatchSafely |
| - describeTo |
| - getApplicationName |
| - getProjectId |
| - getQuery |
| - getUsingStandardSql |
| - queryResultHasChecksum |
| BigtableIO: |
| methods: |
| - advance |
| - close |
| - createReader |
| - expand |
| - finishBundle |
| - getBigtableOptions |
| - getCurrent |
| - getCurrentSource |
| - getEstimatedSizeBytes |
| - getFractionConsumed |
| - getMaxBufferElementCount |
| - getOutputCoder |
| - getRanges |
| - getRowFilter |
| - getSplitPointsConsumed |
| - getTableId |
| - populateDisplayData |
| - processElement |
| - read |
| - split |
| - splitAtFraction |
| - start |
| - startBundle |
| - tearDown |
| - toString |
| - validate |
| - withBigtableOptions |
| - withBigtableOptionsConfigurator |
| - withEmulator |
| - withInstanceId |
| - withKeyRange |
| - withKeyRanges |
| - withMaxBufferElementCount |
| - withProjectId |
| - withRowFilter |
| - withTableId |
| - withWriteResults |
| - withoutValidation |
| - write |
| BigtableRowToBeamRow: |
| methods: |
| - apply |
| - expand |
| BigtableRowToBeamRowFlat: |
| methods: |
| - apply |
| - expand |
| BigtableTable: |
| methods: |
| - buildIOReader |
| - buildIOWriter |
| - constructFilter |
| - isBounded |
| BigtableTableProvider: |
| methods: |
| - buildBeamSqlTable |
| - getTableType |
| BigtableUtils: |
| methods: |
| - booleanToByteArray |
| - byteString |
| - byteStringUtf8 |
| - doubleToByteArray |
| - floatToByteArray |
| - longToByteArray |
| BigtableWriteResult: |
| methods: |
| - create |
| - getRowsWritten |
| BigtableWriteResultCoder: |
| methods: |
| - decode |
| - encode |
| - getCoderProvider |
| - of |
| BitSetCoder: |
| methods: |
| - consistentWithEquals |
| - decode |
| - encode |
| - of |
| - verifyDeterministic |
| BlockBasedSource: |
| methods: |
| - getCurrent |
| - getCurrentBlock |
| - getCurrentBlockOffset |
| - getCurrentBlockSize |
| - getCurrentRecord |
| - getFractionConsumed |
| - getFractionOfBlockConsumed |
| - isAtSplitPoint |
| - readNextBlock |
| - readNextRecord |
| BlockingCommitterImpl: |
| methods: |
| - close |
| - commitOffset |
| BooleanCoder: |
| methods: |
| - consistentWithEquals |
| - decode |
| - encode |
| - isRegisterByteSizeObserverCheap |
| - of |
| BoundedEventSource: |
| methods: |
| - advance |
| - close |
| - createReader |
| - getCurrent |
| - getCurrentSource |
| - getCurrentTimestamp |
| - getDefaultOutputCoder |
| - getEstimatedSizeBytes |
| - getFractionConsumed |
| - split |
| - splitAtFraction |
| - start |
| - validate |
| BoundedReadFromUnboundedSource: |
| methods: |
| - expand |
| - getKindString |
| - populateDisplayData |
| - process |
| - withMaxNumRecords |
| - withMaxReadTime |
| BoundedSideInputJoin: |
| methods: |
| - expand |
| - needsSideInput |
| - processElement |
| BoundedSideInputJoinModel: |
| methods: |
| - simulator |
| BoundedSource: |
| methods: |
| - createReader |
| - getCurrentSource |
| - getCurrentTimestamp |
| - getEstimatedSizeBytes |
| - getFractionConsumed |
| - getSplitPointsConsumed |
| - getSplitPointsRemaining |
| - split |
| - splitAtFraction |
| properties: |
| - SPLIT_POINTS_UNKNOWN |
| BoundedWindow: |
| methods: |
| - formatTimestamp |
| - maxTimestamp |
| - validateTimestampBounds |
| properties: |
| - TIMESTAMP_MAX_VALUE |
| - TIMESTAMP_MIN_VALUE |
| BroadcastHashJoinTranslator: |
| methods: |
| - processElement |
| BucketingFunction: |
| methods: |
| - add |
| - get |
| - isSignificant |
| - remove |
| BufferedElementCountingOutputStream: |
| methods: |
| - close |
| - finish |
| - flush |
| - markElementStart |
| - write |
| properties: |
| - DEFAULT_BUFFER_SIZE |
| BufferedExternalSorter: |
| methods: |
| - add |
| - create |
| - getExternalSorterType |
| - getMemoryMB |
| - getTempLocation |
| - options |
| - sort |
| - withExternalSorterType |
| - withMemoryMB |
| - withTempLocation |
| BufferingStreamObserver: |
| methods: |
| - getBufferSize |
| - getCause |
| - onCompleted |
| - onError |
| - onNext |
| Builders: {} |
| BuiltinHashFunctions: |
| methods: |
| - md5Bytes |
| - md5String |
| - sha1Bytes |
| - sha1String |
| - sha256Bytes |
| - sha256String |
| - sha512Bytes |
| - sha512String |
| BuiltinStringFunctions: |
| methods: |
| - endsWith |
| - fromHex |
| - lengthBytes |
| - lengthString |
| - lpad |
| - reverseBytes |
| - reverseString |
| - rpad |
| - startsWith |
| - toHex |
| BuiltinTrigonometricFunctions: |
| methods: |
| - cosh |
| - sinh |
| - tanh |
| BundleSplitter: {} |
| ByteArrayCoder: |
| methods: |
| - decode |
| - encode |
| - encodeAndOwn |
| - getEncodedTypeDescriptor |
| - isRegisterByteSizeObserverCheap |
| - of |
| - structuralValue |
| - verifyDeterministic |
| ByteBuddyUtils: |
| methods: |
| - appender |
| - apply |
| - clear |
| - containsKey |
| - containsValue |
| - convert |
| - createGetterConversions |
| - createSetterConversions |
| - createTypeConversion |
| - entrySet |
| - equals |
| - get |
| - getTransformingMap |
| - hashCode |
| - isEmpty |
| - isValid |
| - keySet |
| - prepare |
| - put |
| - putAll |
| - remove |
| - size |
| - subclassGetterInterface |
| - subclassSetterInterface |
| - toString |
| - transformContainer |
| - values |
| ByteCoder: |
| methods: |
| - consistentWithEquals |
| - decode |
| - encode |
| - getEncodedTypeDescriptor |
| - isRegisterByteSizeObserverCheap |
| - of |
| - verifyDeterministic |
| ByteKey: |
| methods: |
| - compareTo |
| - copyFrom |
| - equals |
| - getBytes |
| - getValue |
| - hashCode |
| - isEmpty |
| - of |
| - toString |
| properties: |
| - EMPTY |
| ByteKeyRange: |
| methods: |
| - containsKey |
| - equals |
| - estimateFractionForKey |
| - getEndKey |
| - getStartKey |
| - hashCode |
| - interpolateKey |
| - newTracker |
| - of |
| - overlaps |
| - split |
| - toString |
| - withEndKey |
| - withStartKey |
| properties: |
| - ALL_KEYS |
| ByteKeyRangeTracker: |
| methods: |
| - checkDone |
| - currentRestriction |
| - getFractionConsumed |
| - getProgress |
| - getRange |
| - getSplitPointsConsumed |
| - getStartPosition |
| - getStopPosition |
| - isBounded |
| - isDone |
| - markDone |
| - of |
| - toString |
| - tryClaim |
| - tryReturnRecordAt |
| - trySplit |
| - trySplitAtPosition |
| ByteMonitor: |
| methods: |
| - processElement |
| ByteStringCoder: |
| methods: |
| - consistentWithEquals |
| - decode |
| - encode |
| - getEncodedTypeDescriptor |
| - isRegisterByteSizeObserverCheap |
| - of |
| - verifyDeterministic |
| ByteStringOutputStream: |
| methods: |
| - size |
| - toByteString |
| - toByteStringAndReset |
| - toString |
| - write |
| ByteStringOutputStreamBenchmark: |
| methods: |
| - setup |
| - tearDown |
| - testCopyArray |
| - testNewArray |
| - testProtobufByteStringOutputStreamFewLargeWrites |
| - testProtobufByteStringOutputStreamFewMixedWritesWithReuse |
| - testProtobufByteStringOutputStreamFewMixedWritesWithoutReuse |
| - testProtobufByteStringOutputStreamFewSmallWrites |
| - testProtobufByteStringOutputStreamFewTinyWrites |
| - testProtobufByteStringOutputStreamManyLargeWrites |
| - testProtobufByteStringOutputStreamManyMixedWritesWithReuse |
| - testProtobufByteStringOutputStreamManyMixedWritesWithoutReuse |
| - testProtobufByteStringOutputStreamManySmallWrites |
| - testProtobufByteStringOutputStreamManyTinyWrites |
| - testSdkCoreByteStringOutputStreamFewLargeWrites |
| - testSdkCoreByteStringOutputStreamFewMixedWritesWithReuse |
| - testSdkCoreByteStringOutputStreamFewMixedWritesWithoutReuse |
| - testSdkCoreByteStringOutputStreamFewSmallWrites |
| - testSdkCoreByteStringOutputStreamFewTinyWrites |
| - testSdkCoreByteStringOutputStreamManyLargeWrites |
| - testSdkCoreByteStringOutputStreamManyMixedWritesWithReuse |
| - testSdkCoreByteStringOutputStreamManyMixedWritesWithoutReuse |
| - testSdkCoreByteStringOutputStreamManySmallWrites |
| - testSdkCoreByteStringOutputStreamManyTinyWrites |
| properties: |
| - src |
| BytesThroughputEstimator: |
| methods: |
| - addBytes |
| - get |
| - getBytes |
| - getFrom |
| - getSeconds |
| - getTimestamp |
| - update |
| CEPCall: |
| methods: |
| - getOperands |
| - getOperator |
| - of |
| - toString |
| CEPFieldRef: |
| methods: |
| - getAlpha |
| - getIndex |
| - of |
| - toString |
| CEPLiteral: |
| methods: |
| - compareTo |
| - equals |
| - getBoolean |
| - getByte |
| - getDateTime |
| - getDecimal |
| - getDouble |
| - getFloat |
| - getInt16 |
| - getInt32 |
| - getInt64 |
| - getString |
| - getTypeName |
| - hashCode |
| - of |
| CEPMeasure: |
| methods: |
| - getField |
| - getName |
| - getOperation |
| - getType |
| CEPOperation: |
| methods: |
| - of |
| CEPOperator: |
| methods: |
| - getCepKind |
| - of |
| - toString |
| CEPPattern: |
| methods: |
| - getPatternCondition |
| - getPatternVar |
| - getQuantifier |
| - of |
| - toString |
| CEPUtils: |
| methods: |
| - getCEPFieldRefFromParKeys |
| - getCEPPatternFromPattern |
| - getFieldRef |
| - getFieldType |
| - getRegexFromPattern |
| - makeOrderKeysFromCollation |
| Caches: |
| methods: |
| - clear |
| - computeIfAbsent |
| - describeStats |
| - equals |
| - eternal |
| - fromOptions |
| - getCache |
| - getWeight |
| - hashCode |
| - noop |
| - onRemoval |
| - peek |
| - put |
| - remove |
| - subCache |
| - toString |
| - weigh |
| properties: |
| - REFERENCE_SIZE |
| - ROOT |
| CachingFactory: |
| methods: |
| - create |
| - equals |
| - hashCode |
| CalcRelSplitter: |
| methods: |
| - canImplement |
| - execute |
| - getMaxUsingLevelOrdinals |
| - maxInputFor |
| - toString |
| - visitCall |
| - visitDynamicParam |
| - visitFieldAccess |
| - visitInputRef |
| - visitLiteral |
| - visitLocalRef |
| CalciteConnectionWrapper: |
| methods: |
| - abort |
| - clearWarnings |
| - close |
| - commit |
| - config |
| - createArrayOf |
| - createBlob |
| - createClob |
| - createNClob |
| - createPrepareContext |
| - createQuery |
| - createSQLXML |
| - createStatement |
| - createStruct |
| - execute |
| - executeQuery |
| - getAutoCommit |
| - getCatalog |
| - getClientInfo |
| - getHoldability |
| - getMetaData |
| - getNetworkTimeout |
| - getProperties |
| - getRootSchema |
| - getSchema |
| - getTransactionIsolation |
| - getTypeFactory |
| - getTypeMap |
| - getWarnings |
| - isClosed |
| - isReadOnly |
| - isValid |
| - isWrapperFor |
| - nativeSQL |
| - prepareCall |
| - prepareStatement |
| - releaseSavepoint |
| - rollback |
| - setAutoCommit |
| - setCatalog |
| - setClientInfo |
| - setHoldability |
| - setNetworkTimeout |
| - setReadOnly |
| - setSavepoint |
| - setSchema |
| - setTransactionIsolation |
| - setTypeMap |
| - unwrap |
| CalciteFactoryWrapper: |
| methods: |
| - newConnection |
| - newDatabaseMetaData |
| - newPreparedStatement |
| - newResultSet |
| - newResultSetMetaData |
| - newStatement |
| CalciteQueryPlanner: |
| methods: |
| - convertToBeamRel |
| - createPlanner |
| - defaultConfig |
| - getDef |
| - getNonCumulativeCost |
| - parse |
| properties: |
| - FACTORY |
| - SOURCE |
| CalciteUtils: |
| methods: |
| - isDateTimeType |
| - isStringType |
| - sqlTypeWithAutoCast |
| - toCalciteRowType |
| - toField |
| - toFieldType |
| - toRelDataType |
| - toSchema |
| - toSqlTypeName |
| properties: |
| - BIG_INT |
| - BOOLEAN |
| - CHAR |
| - DATE |
| - DECIMAL |
| - DOUBLE |
| - FLOAT |
| - IDENTIFIER |
| - INTEGER |
| - NULLABLE_DATE |
| - NULLABLE_TIME |
| - NULLABLE_TIMESTAMP |
| - NULLABLE_TIMESTAMP_WITH_LOCAL_TZ |
| - SMALL_INT |
| - TIME |
| - TIMESTAMP |
| - TIMESTAMP_WITH_LOCAL_TZ |
| - TIME_WITH_LOCAL_TZ |
| - TINY_INT |
| - VARBINARY |
| - VARCHAR |
| CalendarWindows: |
| methods: |
| - assignWindow |
| - beginningOnDay |
| - days |
| - getDayOfMonth |
| - getMonthOfYear |
| - getNumber |
| - getStartDate |
| - getTimeZone |
| - isCompatible |
| - months |
| - populateDisplayData |
| - verifyCompatibility |
| - weeks |
| - windowCoder |
| - withStartingDay |
| - withStartingMonth |
| - withStartingYear |
| - withTimeZone |
| - years |
| CancellableQueue: |
| methods: |
| - cancel |
| - put |
| - reset |
| - take |
| CannotProvideCoderException: |
| methods: |
| - getReason |
| - getRootCause |
| CassandraIO: |
| methods: |
| - build |
| - delete |
| - expand |
| - finishBundle |
| - process |
| - processElement |
| - read |
| - readAll |
| - setup |
| - teardown |
| - validate |
| - withCoder |
| - withConnectTimeout |
| - withConsistencyLevel |
| - withEntity |
| - withHosts |
| - withKeyspace |
| - withLocalDc |
| - withMapperFactoryFn |
| - withMinNumberOfSplits |
| - withPassword |
| - withPort |
| - withQuery |
| - withReadTimeout |
| - withRingRanges |
| - withTable |
| - withUsername |
| - write |
| Cast: |
| methods: |
| - accept |
| - accumulate |
| - apply |
| - castNumber |
| - castRow |
| - castValue |
| - create |
| - expand |
| - isDecimal |
| - isIntegral |
| - message |
| - narrowing |
| - of |
| - outputSchema |
| - path |
| - process |
| - toString |
| - validator |
| - verifyCompatibility |
| - widening |
| CastFunctionImpl: |
| methods: |
| - getImplementor |
| - getParameters |
| - implement |
| CategoryPrice: |
| methods: |
| - decode |
| - encode |
| - equals |
| - hashCode |
| - sizeInBytes |
| - structuralValue |
| - toString |
| - verifyDeterministic |
| properties: |
| - CODER |
| - category |
| - isLast |
| - price |
| CdapIO: |
| methods: |
| - expand |
| - read |
| - withCdapPlugin |
| - withCdapPluginClass |
| - withKeyClass |
| - withLocksDirPath |
| - withPluginConfig |
| - withPullFrequencySec |
| - withStartOffset |
| - withValueClass |
| - write |
| ChangeStreamDao: |
| methods: |
| - changeStreamQuery |
| ChangeStreamMetrics: |
| methods: |
| - decActivePartitionReadCounter |
| - incActivePartitionReadCounter |
| - incDataRecordCounter |
| - incHeartbeatRecordCount |
| - incPartitionRecordCount |
| - incPartitionRecordMergeCount |
| - incPartitionRecordSplitCount |
| - incQueryCounter |
| - updateDataRecordCommittedToEmitted |
| - updatePartitionCreatedToScheduled |
| - updatePartitionScheduledToRunning |
| properties: |
| - ACTIVE_PARTITION_READ_COUNT |
| - DATA_RECORD_COMMITTED_TO_EMITTED_0MS_TO_1000MS_COUNT |
| - DATA_RECORD_COMMITTED_TO_EMITTED_1000MS_TO_3000MS_COUNT |
| - DATA_RECORD_COMMITTED_TO_EMITTED_3000MS_TO_INF_COUNT |
| - DATA_RECORD_COUNT |
| - HEARTBEAT_RECORD_COUNT |
| - PARTITION_CREATED_TO_SCHEDULED_MS |
| - PARTITION_RECORD_COUNT |
| - PARTITION_RECORD_MERGE_COUNT |
| - PARTITION_RECORD_SPLIT_COUNT |
| - PARTITION_SCHEDULED_TO_RUNNING_MS |
| - QUERY_COUNT |
| ChangeStreamRecordMapper: |
| methods: |
| - toChangeStreamRecords |
| ChangeStreamRecordMetadata: |
| methods: |
| - build |
| - equals |
| - getNumberOfRecordsRead |
| - getPartitionCreatedAt |
| - getPartitionEndTimestamp |
| - getPartitionRunningAt |
| - getPartitionScheduledAt |
| - getPartitionStartTimestamp |
| - getPartitionToken |
| - getQueryStartedAt |
| - getRecordReadAt |
| - getRecordStreamEndedAt |
| - getRecordStreamStartedAt |
| - getRecordTimestamp |
| - getTotalStreamTimeMillis |
| - hashCode |
| - newBuilder |
| - toString |
| - withNumberOfRecordsRead |
| - withPartitionCreatedAt |
| - withPartitionEndTimestamp |
| - withPartitionRunningAt |
| - withPartitionScheduledAt |
| - withPartitionStartTimestamp |
| - withPartitionToken |
| - withQueryStartedAt |
| - withRecordReadAt |
| - withRecordStreamEndedAt |
| - withRecordStreamStartedAt |
| - withRecordTimestamp |
| - withTotalStreamTimeMillis |
| ChangeStreamResultSet: |
| methods: |
| - close |
| - getCurrentRowAsStruct |
| - getMetadata |
| - getPgJsonb |
| - next |
| ChangeStreamResultSetMetadata: |
| methods: |
| - getNumberOfRecordsRead |
| - getQueryStartedAt |
| - getRecordReadAt |
| - getRecordStreamEndedAt |
| - getRecordStreamStartedAt |
| - getTotalStreamDuration |
| ChangeStreamsConstants: |
| properties: |
| - DEFAULT_CHANGE_STREAM_NAME |
| - DEFAULT_INCLUSIVE_END_AT |
| - DEFAULT_INCLUSIVE_START_AT |
| - DEFAULT_RPC_PRIORITY |
| - MAX_INCLUSIVE_END_AT |
| - SAMPLE_PARTITION |
| - THROUGHPUT_WINDOW_SECONDS |
| CheckpointMarkImpl: |
| methods: |
| - decode |
| - encode |
| - finalizeCheckpoint |
| ChildPartition: |
| methods: |
| - equals |
| - getParentTokens |
| - getToken |
| - hashCode |
| - toString |
| ChildPartitionsRecord: |
| methods: |
| - equals |
| - getChildPartitions |
| - getRecordSequence |
| - getRecordTimestamp |
| - getStartTimestamp |
| - hashCode |
| - toString |
| ChildPartitionsRecordAction: |
| methods: |
| - run |
| CivilTimeEncoder: |
| methods: |
| - decodePacked32TimeSeconds |
| - decodePacked32TimeSecondsAsJavaTime |
| - decodePacked64DatetimeMicros |
| - decodePacked64DatetimeMicrosAsJavaTime |
| - decodePacked64DatetimeSeconds |
| - decodePacked64DatetimeSecondsAsJavaTime |
| - decodePacked64TimeMicros |
| - decodePacked64TimeMicrosAsJavaTime |
| - decodePacked64TimeNanos |
| - decodePacked64TimeNanosAsJavaTime |
| - encodePacked32TimeSeconds |
| - encodePacked64DatetimeMicros |
| - encodePacked64DatetimeSeconds |
| - encodePacked64TimeMicros |
| - encodePacked64TimeNanos |
| ClassLoaderFileSystem: |
| methods: |
| - fromOptions |
| - getCurrentDirectory |
| - getFilename |
| - getScheme |
| - isDirectory |
| - resolve |
| properties: |
| - SCHEMA |
| CleanUpReadChangeStreamDoFn: |
| methods: |
| - processElement |
| ClickHouseIO: |
| methods: |
| - build |
| - expand |
| - finishBundle |
| - getTableSchema |
| - initialBackoff |
| - insertDeduplicate |
| - insertDistributedSync |
| - insertQuorum |
| - jdbcUrl |
| - maxCumulativeBackoff |
| - maxInsertBlockSize |
| - maxRetries |
| - processElement |
| - properties |
| - schema |
| - setup |
| - startBundle |
| - table |
| - tableSchema |
| - tearDown |
| - withInitialBackoff |
| - withInsertDeduplicate |
| - withInsertDistributedSync |
| - withInsertQuorum |
| - withMaxCumulativeBackoff |
| - withMaxInsertBlockSize |
| - withMaxRetries |
| - withTableSchema |
| - write |
| properties: |
| - DEFAULT_INITIAL_BACKOFF |
| - DEFAULT_MAX_CUMULATIVE_BACKOFF |
| - DEFAULT_MAX_INSERT_BLOCK_SIZE |
| - DEFAULT_MAX_RETRIES |
| ClickHouseWriter: {} |
| ClientConfiguration: |
| methods: |
| - build |
| - builder |
| - create |
| - credentialsProvider |
| - endpoint |
| - region |
| - retry |
| - toBuilder |
| CloudPubsubTransforms: |
| methods: |
| - ensureUsableAsCloudPubsub |
| - expand |
| - fromCloudPubsubMessages |
| - toCloudPubsubMessages |
| CloudVision: |
| methods: |
| - annotateImagesFromBytes |
| - annotateImagesFromBytesWithContext |
| - annotateImagesFromGcsUri |
| - annotateImagesFromGcsUriWithContext |
| - mapToRequest |
| CoGbkResult: |
| methods: |
| - and |
| - copy |
| - decode |
| - done |
| - empty |
| - encode |
| - equals |
| - fastForward |
| - getAll |
| - getCoderArguments |
| - getOnly |
| - getSchema |
| - getUnionCoder |
| - hasNext |
| - hashCode |
| - isEmpty |
| - iterator |
| - next |
| - observeAt |
| - of |
| - peek |
| - toString |
| - verifyDeterministic |
| properties: |
| - index |
| - value |
| CoGbkResultSchema: |
| methods: |
| - equals |
| - getIndex |
| - getTag |
| - getTupleTagList |
| - hashCode |
| - of |
| - size |
| - toString |
| CoGroup: |
| methods: |
| - crossProductJoin |
| - expand |
| - fieldAccessDescriptor |
| - fieldIds |
| - fieldNames |
| - join |
| - process |
| - withKeyField |
| - withOptionalParticipation |
| - withSideInput |
| CoGroupByKey: |
| methods: |
| - create |
| - expand |
| - processElement |
| CoGroupByKeyLoadTest: |
| methods: |
| - main |
| - processElement |
| Coder: |
| methods: |
| - consistentWithEquals |
| - decode |
| - encode |
| - equals |
| - getCoderArguments |
| - getEncodedTypeDescriptor |
| - getMessage |
| - getReasons |
| - hashCode |
| - isRegisterByteSizeObserverCheap |
| - nested |
| - registerByteSizeObserver |
| - structuralValue |
| - toString |
| - verifyDeterministic |
| properties: |
| - NESTED |
| - OUTER |
| - isWholeStream |
| CoderException: {} |
| CoderProperties: |
| methods: |
| - coderConsistentWithEquals |
| - coderConsistentWithEqualsInContext |
| - coderDecodeEncodeContentsEqual |
| - coderDecodeEncodeContentsEqualInContext |
| - coderDecodeEncodeContentsInSameOrder |
| - coderDecodeEncodeContentsInSameOrderInContext |
| - coderDecodeEncodeEqual |
| - coderDecodeEncodeEqualInContext |
| - coderDecodeEncodeInContext |
| - coderDecodesBase64 |
| - coderDecodesBase64ContentsEqual |
| - coderDeterministic |
| - coderDeterministicInContext |
| - coderEncodesBase64 |
| - coderSerializable |
| - getCount |
| - getMean |
| - getSum |
| - getSumAndReset |
| - reset |
| - structuralValueConsistentWithEquals |
| - structuralValueConsistentWithEqualsInContext |
| - structuralValueDecodeEncodeEqual |
| - structuralValueDecodeEncodeEqualInContext |
| - structuralValueDecodeEncodeEqualIterable |
| - structuralValueDecodeEncodeEqualIterableInContext |
| - testByteCount |
| properties: |
| - ALL_CONTEXTS |
| CoderProvider: |
| methods: |
| - coderFor |
| CoderProviders: |
| methods: |
| - coderFor |
| - forCoder |
| - fromStaticMethods |
| - toString |
| CoderRegistry: |
| methods: |
| - coderFor |
| - createDefault |
| - getCoder |
| - getOutputCoder |
| - getType |
| - registerCoderForClass |
| - registerCoderForType |
| - registerCoderProvider |
| CoderUtils: |
| methods: |
| - clone |
| - decodeFromBase64 |
| - decodeFromByteArray |
| - decodeFromByteString |
| - encodeToBase64 |
| - encodeToByteArray |
| - getCodedType |
| CollectionCoder: |
| methods: |
| - getEncodedTypeDescriptor |
| - of |
| ColumnType: |
| methods: |
| - equals |
| - getName |
| - getOrdinalPosition |
| - getType |
| - hashCode |
| - isPrimaryKey |
| - toString |
| Combine: |
| methods: |
| - accum |
| - addInput |
| - apply |
| - asSingletonView |
| - compact |
| - createAccumulator |
| - decode |
| - defaultValue |
| - encode |
| - equals |
| - expand |
| - extractOutput |
| - getAccumulatorCoder |
| - getAdditionalInputs |
| - getAppliedFn |
| - getCoderArguments |
| - getCombineFn |
| - getDefaultOutputCoder |
| - getFanout |
| - getFn |
| - getInputType |
| - getInsertDefault |
| - getNameOverride |
| - getOutputType |
| - getPipelineOptions |
| - getSideInputs |
| - globally |
| - groupedValues |
| - hashCode |
| - identity |
| - input |
| - isInsertDefault |
| - mergeAccumulators |
| - of |
| - perKey |
| - populateDisplayData |
| - processElement |
| - sideInput |
| - startBundle |
| - toString |
| - verifyDeterministic |
| - withFanout |
| - withHotKeyFanout |
| - withSideInputs |
| - withoutDefaults |
| properties: |
| - accum |
| - input |
| CombineContextFactory: |
| methods: |
| - createFromStateContext |
| - getPipelineOptions |
| - nullContext |
| - sideInput |
| CombineFnBase: |
| methods: |
| - getAccumTVariable |
| - getAccumulatorCoder |
| - getDefaultOutputCoder |
| - getIncompatibleGlobalWindowErrorMessage |
| - getInputTVariable |
| - getOutputTVariable |
| - populateDisplayData |
| CombineFnTester: |
| methods: |
| - testCombineFn |
| CombineFnUtil: |
| methods: |
| - addInput |
| - bindContext |
| - compact |
| - createAccumulator |
| - defaultValue |
| - extractOutput |
| - getAccumulatorCoder |
| - getDefaultOutputCoder |
| - mergeAccumulators |
| - populateDisplayData |
| - toFnWithContext |
| CombineFns: |
| methods: |
| - addInput |
| - compact |
| - compose |
| - createAccumulator |
| - decode |
| - encode |
| - equals |
| - extractOutput |
| - get |
| - getAccumulatorCoder |
| - getCoderArguments |
| - hasNext |
| - hashCode |
| - iterator |
| - mergeAccumulators |
| - next |
| - populateDisplayData |
| - remove |
| - verifyDeterministic |
| - with |
| CombineLoadTest: |
| methods: |
| - apply |
| - getPerKeyCombiner |
| - main |
| CombineRunners: |
| methods: |
| - createRunnerForPTransform |
| - getPTransformRunnerFactories |
| CombineWithContext: |
| methods: |
| - addInput |
| - apply |
| - compact |
| - createAccumulator |
| - defaultValue |
| - extractOutput |
| - getPipelineOptions |
| - mergeAccumulators |
| - sideInput |
| CompletableFutureInboundDataClient: |
| methods: |
| - awaitCompletion |
| - cancel |
| - complete |
| - create |
| - fail |
| - isDone |
| - runWhenComplete |
| CompositeOperatorTranslator: |
| methods: |
| - canTranslate |
| - translate |
| CompositeProvider: |
| methods: |
| - findTranslator |
| - of |
| CompositeUnaryFunction: |
| methods: |
| - apply |
| - of |
| CompressedSource: |
| methods: |
| - allowsDynamicSplitting |
| - close |
| - createDecompressingChannel |
| - from |
| - getChannelFactory |
| - getCount |
| - getCurrent |
| - getCurrentTimestamp |
| - getOutputCoder |
| - getSplitPointsConsumed |
| - getSplitPointsRemaining |
| - isCompressed |
| - isOpen |
| - matches |
| - populateDisplayData |
| - read |
| - validate |
| - withCompression |
| - withDecompression |
| ConfigWrapper: |
| methods: |
| - build |
| - fromJsonFile |
| - fromJsonString |
| - setParam |
| - withParams |
| ConfluentSchemaRegistryDeserializerProvider: |
| methods: |
| - getCoder |
| - getDeserializer |
| - of |
| ConnectionManager: {} |
| ConsoleResultPublisher: |
| methods: |
| - publish |
| Contextful: |
| methods: |
| - fn |
| - getClosure |
| - getRequirements |
| - of |
| - sideInput |
| - toString |
| - wrapProcessContext |
| ContextualTextIO: |
| methods: |
| - apply |
| - compare |
| - expand |
| - from |
| - populateDisplayData |
| - processElement |
| - read |
| - readFiles |
| - withCompression |
| - withDelimiter |
| - withEmptyMatchTreatment |
| - withHasMultilineCSVRecords |
| - withHintMatchesManyFiles |
| - withMatchConfiguration |
| - withRecordNumMetadata |
| ConversionContext: |
| methods: |
| - of |
| Convert: |
| methods: |
| - expand |
| - fromRows |
| - processElement |
| - to |
| - toRows |
| ConvertHelpers: |
| methods: |
| - appender |
| - getConvertPrimitive |
| - getConvertedSchemaInformation |
| - prepare |
| properties: |
| - outputSchemaCoder |
| - unboxedType |
| Count: |
| methods: |
| - addInput |
| - apply |
| - combineFn |
| - createAccumulator |
| - decode |
| - encode |
| - equals |
| - expand |
| - extractOutput |
| - getAccumulatorCoder |
| - getIncompatibleGlobalWindowErrorMessage |
| - globally |
| - hashCode |
| - isRegisterByteSizeObserverCheap |
| - mergeAccumulators |
| - perElement |
| - perKey |
| CountByKey: |
| methods: |
| - accumulationMode |
| - expand |
| - keyBy |
| - named |
| - of |
| - output |
| - triggeredBy |
| - windowBy |
| - withAllowedLateness |
| - withOnTimeBehavior |
| - withTimestampCombiner |
| CountIf: |
| methods: |
| - addInput |
| - combineFn |
| - createAccumulator |
| - extractOutput |
| - getAccumulatorCoder |
| - mergeAccumulators |
| CountingSource: |
| methods: |
| - advance |
| - apply |
| - close |
| - createReader |
| - createSourceForSubrange |
| - equals |
| - finalizeCheckpoint |
| - getBytesPerOffset |
| - getCheckpointMark |
| - getCheckpointMarkCoder |
| - getCurrent |
| - getCurrentSource |
| - getCurrentTimestamp |
| - getLastEmitted |
| - getMaxEndOffset |
| - getOutputCoder |
| - getSplitBacklogBytes |
| - getSplitPointsRemaining |
| - getStartTime |
| - getWatermark |
| - hashCode |
| - split |
| - start |
| - unbounded |
| - unboundedWithTimestampFn |
| - upTo |
| - withRate |
| - withTimestampFn |
| CovarianceFn: |
| methods: |
| - addInput |
| - createAccumulator |
| - extractOutput |
| - getAccumulatorCoder |
| - mergeAccumulators |
| - newPopulation |
| - newSample |
| CrashingRunner: |
| methods: |
| - fromOptions |
| - run |
| Create: |
| methods: |
| - apply |
| - close |
| - createReader |
| - createSourceForSubrange |
| - empty |
| - expand |
| - fromIterable |
| - getBytesPerOffset |
| - getCurrent |
| - getCurrentSource |
| - getElements |
| - getEstimatedSizeBytes |
| - getMaxEndOffset |
| - getOutputCoder |
| - of |
| - ofProvider |
| - processElement |
| - timestamped |
| - withCoder |
| - withRowSchema |
| - withSchema |
| - withType |
| CreateOptions: |
| methods: |
| - build |
| - builder |
| - expectFileToNotExist |
| - mimeType |
| - setExpectFileToNotExist |
| - setMimeType |
| CreateTableDestinations: |
| methods: |
| - expand |
| - processElement |
| - startBundle |
| CreateTableHelpers: {} |
| CreateTables: |
| methods: |
| - expand |
| - processElement |
| - startBundle |
| CrossLanguageConfiguration: |
| methods: |
| - getDataSourceConfiguration |
| - getDatabase |
| - getOAuthToken |
| - getPassword |
| - getPrivateKeyPassphrase |
| - getPrivateKeyPath |
| - getQuery |
| - getRawPrivateKey |
| - getRole |
| - getSchema |
| - getServerName |
| - getStagingBucketName |
| - getStorageIntegrationName |
| - getTable |
| - getUsername |
| - getWarehouse |
| - setDatabase |
| - setOAuthToken |
| - setPassword |
| - setPrivateKeyPassphrase |
| - setPrivateKeyPath |
| - setQuery |
| - setRawPrivateKey |
| - setRole |
| - setSchema |
| - setServerName |
| - setStagingBucketName |
| - setStorageIntegrationName |
| - setTable |
| - setUsername |
| - setWarehouse |
| CsvToRow: |
| methods: |
| - expand |
| - getCsvFormat |
| CustomCoder: |
| methods: |
| - getCoderArguments |
| - verifyDeterministic |
| CustomHttpErrors: |
| methods: |
| - addErrorForCode |
| - addErrorForCodeAndUrlContains |
| - build |
| - getCustomError |
| - getMatcher |
| CustomTimestampPolicyWithLimitedDelay: |
| methods: |
| - getTimestampForRecord |
| - getWatermark |
| CustomX509TrustManager: |
| methods: |
| - checkClientTrusted |
| - checkServerTrusted |
| - getAcceptedIssuers |
| Customer: |
| methods: |
| - equals |
| - getCountryOfResidence |
| - getId |
| - getName |
| - hashCode |
| - setCountryOfResidence |
| - setId |
| - setName |
| - toString |
| DLPDeidentifyText: |
| methods: |
| - build |
| - expand |
| - getBatchSizeBytes |
| - getColumnDelimiter |
| - getDeidentifyConfig |
| - getDeidentifyTemplateName |
| - getHeaderColumns |
| - getInspectConfig |
| - getInspectTemplateName |
| - getProjectId |
| - newBuilder |
| - processElement |
| - setBatchSizeBytes |
| - setColumnDelimiter |
| - setDeidentifyConfig |
| - setDeidentifyTemplateName |
| - setHeaderColumns |
| - setInspectConfig |
| - setInspectTemplateName |
| - setProjectId |
| - setup |
| - teardown |
| properties: |
| - DLP_PAYLOAD_LIMIT_BYTES |
| DLPInspectText: |
| methods: |
| - build |
| - expand |
| - getBatchSizeBytes |
| - getColumnDelimiter |
| - getHeaderColumns |
| - getInspectConfig |
| - getInspectTemplateName |
| - getProjectId |
| - newBuilder |
| - processElement |
| - setBatchSizeBytes |
| - setColumnDelimiter |
| - setHeaderColumns |
| - setInspectConfig |
| - setInspectTemplateName |
| - setProjectId |
| - setup |
| - teardown |
| properties: |
| - DLP_PAYLOAD_LIMIT_BYTES |
| DLPReidentifyText: |
| methods: |
| - build |
| - expand |
| - getBatchSizeBytes |
| - getColumnDelimiter |
| - getHeaderColumns |
| - getInspectConfig |
| - getInspectTemplateName |
| - getProjectId |
| - getReidentifyConfig |
| - getReidentifyTemplateName |
| - newBuilder |
| - processElement |
| - setBatchSizeBytes |
| - setColumnDelimiter |
| - setHeaderColumns |
| - setInspectConfig |
| - setInspectTemplateName |
| - setProjectId |
| - setReidentifyConfig |
| - setReidentifyTemplateName |
| - setup |
| - teardown |
| properties: |
| - DLP_PAYLOAD_LIMIT_BYTES |
| DaoFactory: |
| methods: |
| - getChangeStreamDao |
| - getPartitionMetadataAdminDao |
| - getPartitionMetadataDao |
| DataCatalogPipelineOptionsRegistrar: |
| methods: |
| - getPipelineOptions |
| DataCatalogTableProvider: |
| methods: |
| - buildBeamSqlTable |
| - close |
| - create |
| - createDataCatalogClient |
| - createTable |
| - dropTable |
| - getTable |
| - getTableByFullName |
| - getTableType |
| - getTables |
| - setSchemaIfNotPresent |
| DataChangeRecord: |
| methods: |
| - equals |
| - getCommitTimestamp |
| - getMetadata |
| - getModType |
| - getMods |
| - getNumberOfPartitionsInTransaction |
| - getNumberOfRecordsInTransaction |
| - getPartitionToken |
| - getRecordSequence |
| - getRecordTimestamp |
| - getRowType |
| - getServerTransactionId |
| - getTableName |
| - getTransactionTag |
| - getValueCaptureType |
| - hashCode |
| - isLastRecordInTransactionInPartition |
| - isSystemTransaction |
| - toString |
| DataChangeRecordAction: |
| methods: |
| - run |
| DataEndpoint: |
| methods: |
| - create |
| - getCoder |
| - getReceiver |
| - getTransformId |
| DataStoreV1SchemaIOProvider: |
| methods: |
| - buildReader |
| - buildWriter |
| - configurationSchema |
| - expand |
| - from |
| - getKind |
| - getProjectId |
| - identifier |
| - isBounded |
| - requiresDataSchema |
| - schema |
| properties: |
| - KEY_FIELD_PROPERTY |
| DataStoreV1TableProvider: |
| methods: |
| - getSchemaIOProvider |
| - getTableStatistics |
| - getTableType |
| DataStreams: |
| methods: |
| - close |
| - decodeFromChunkBoundaryToChunkBoundary |
| - delimitElement |
| - hasNext |
| - isEof |
| - isReady |
| - next |
| - outbound |
| - prefetch |
| - read |
| - remove |
| - write |
| properties: |
| - DEFAULT_OUTBOUND_BUFFER_LIMIT_BYTES |
| DataframeTransform: |
| methods: |
| - expand |
| - of |
| - withExpansionService |
| - withIndexes |
| DatastoreIO: |
| methods: |
| - v1 |
| DatastoreV1: |
| methods: |
| - addRequestLatency |
| - apply |
| - deleteEntity |
| - deleteKey |
| - expand |
| - finishBundle |
| - from |
| - getDatastore |
| - getLiteralGqlQuery |
| - getLocalhost |
| - getNamespace |
| - getNamespaceValueProvider |
| - getNumEntities |
| - getNumQuerySplits |
| - getProjectId |
| - getProjectValueProvider |
| - getQuery |
| - getQuerySplitter |
| - getReadTime |
| - nextBatchSize |
| - populateDisplayData |
| - processElement |
| - read |
| - start |
| - startBundle |
| - toString |
| - withHintNumWorkers |
| - withLiteralGqlQuery |
| - withLocalhost |
| - withNamespace |
| - withNumQuerySplits |
| - withProjectId |
| - withQuery |
| - withRampupThrottlingDisabled |
| - withReadTime |
| - write |
| properties: |
| - NUM_QUERY_SPLITS_MAX |
| Date: |
| methods: |
| - getArgument |
| - getArgumentType |
| - getBaseType |
| - getIdentifier |
| - toBaseType |
| - toInputType |
| properties: |
| - IDENTIFIER |
| DateFunctions: |
| methods: |
| - date |
| DateTime: |
| methods: |
| - getArgument |
| - getArgumentType |
| - getBaseType |
| - getIdentifier |
| - toBaseType |
| - toInputType |
| properties: |
| - DATETIME_SCHEMA |
| - DATE_FIELD_NAME |
| - IDENTIFIER |
| - TIME_FIELD_NAME |
| DateTimeUtils: |
| methods: |
| - findDateTimePattern |
| - formatTimestampWithTimeZone |
| - parseDate |
| - parseDateToValue |
| - parseTime |
| - parseTimeToValue |
| - parseTimestampWithLocalTimeZone |
| - parseTimestampWithTZToValue |
| - parseTimestampWithTimeZone |
| - parseTimestampWithUTCTimeZone |
| - parseTimestampWithoutTimeZone |
| - validateTimeInterval |
| - validateTimestamp |
| properties: |
| - MAX_UNIX_MILLIS |
| - MILLIS_PER_DAY |
| - MIN_UNIX_MILLIS |
| DeadLetteredTransform: |
| methods: |
| - expand |
| DebeziumIO: |
| methods: |
| - create |
| - expand |
| - getConfigurationMap |
| - read |
| - readAsJson |
| - withCoder |
| - withConnectionProperties |
| - withConnectionProperty |
| - withConnectorClass |
| - withConnectorConfiguration |
| - withFormatFunction |
| - withHostName |
| - withMaxNumberOfRecords |
| - withMaxTimeToRun |
| - withPassword |
| - withPort |
| - withSourceConnector |
| - withUsername |
| DebeziumReadSchemaTransformProvider: |
| methods: |
| - build |
| - buildTransform |
| - builder |
| - expand |
| - getDatabase |
| - getDebeziumConnectionProperties |
| - getHost |
| - getPassword |
| - getPort |
| - getTable |
| - getUsername |
| - identifier |
| - inputCollectionNames |
| - outputCollectionNames |
| - setDatabase |
| - setDebeziumConnectionProperties |
| - setHost |
| - setPassword |
| - setPort |
| - setTable |
| - setUsername |
| DebeziumTransformRegistrar: |
| methods: |
| - buildExternal |
| - knownBuilders |
| - setConnectionProperties |
| - setConnectorClass |
| - setHost |
| - setMaxNumberOfRecords |
| - setPassword |
| - setPort |
| - setUsername |
| properties: |
| - READ_JSON_URN |
| DecodingFnDataReceiver: |
| methods: |
| - accept |
| - create |
| Deduplicate: |
| methods: |
| - apply |
| - expand |
| - keyedValues |
| - onExpiry |
| - processElement |
| - values |
| - withDuration |
| - withRepresentativeCoder |
| - withRepresentativeType |
| - withRepresentativeValueFn |
| - withTimeDomain |
| properties: |
| - DEFAULT_DURATION |
| - DEFAULT_TIME_DOMAIN |
| DefaultAutoscaler: |
| methods: |
| - getTotalBacklogBytes |
| - start |
| - stop |
| DefaultBlobstoreClientBuilderFactory: |
| methods: |
| - createBuilder |
| DefaultFilenamePolicy: |
| methods: |
| - constructName |
| - decode |
| - encode |
| - equals |
| - fromParams |
| - fromStandardParameters |
| - hashCode |
| - of |
| - populateDisplayData |
| - toString |
| - unwindowedFilename |
| - windowedFilename |
| - withBaseFilename |
| - withShardTemplate |
| - withSuffix |
| - withWindowedWrites |
| properties: |
| - DEFAULT_UNWINDOWED_SHARD_TEMPLATE |
| - DEFAULT_WINDOWED_SHARD_TEMPLATE |
| DefaultPipelineOptionsRegistrar: |
| methods: |
| - getPipelineOptions |
| DefaultS3ClientBuilderFactory: |
| methods: |
| - createBuilder |
| DefaultS3FileSystemSchemeRegistrar: |
| methods: |
| - fromOptions |
| DefaultTableFilter: |
| methods: |
| - getNotSupported |
| - numSupported |
| DefaultTrigger: |
| methods: |
| - getWatermarkThatGuaranteesFiring |
| - isCompatible |
| - mayFinish |
| - of |
| DelegateCoder: |
| methods: |
| - decode |
| - encode |
| - equals |
| - getCoder |
| - getEncodedTypeDescriptor |
| - hashCode |
| - of |
| - structuralValue |
| - toString |
| - verifyDeterministic |
| DelegatingCounter: |
| methods: |
| - dec |
| - getName |
| - inc |
| DelegatingDistribution: |
| methods: |
| - getName |
| - update |
| DelegatingHistogram: |
| methods: |
| - getName |
| - update |
| DequeCoder: |
| methods: |
| - consistentWithEquals |
| - getEncodedTypeDescriptor |
| - of |
| - structuralValue |
| - verifyDeterministic |
| DetectNewPartitionsAction: |
| methods: |
| - run |
| DetectNewPartitionsDoFn: |
| methods: |
| - getInitialWatermarkEstimatorState |
| - getSize |
| - initialRestriction |
| - newTracker |
| - newWatermarkEstimator |
| - processElement |
| - setAveragePartitionBytesSize |
| - setup |
| DetectNewPartitionsRangeTracker: |
| methods: |
| - tryClaim |
| DicomIO: |
| methods: |
| - expand |
| - finishSpecifyingOutput |
| - getFailedReads |
| - getPipeline |
| - getReadResponse |
| - instantiateHealthcareClient |
| - processElement |
| - readStudyMetadata |
| properties: |
| - ERROR_MESSAGE |
| - METADATA |
| DirectStreamObserver: |
| methods: |
| - onCompleted |
| - onError |
| - onNext |
| DisplayData: |
| methods: |
| - absolute |
| - add |
| - addIfNotDefault |
| - addIfNotNull |
| - asMap |
| - build |
| - delegate |
| - equals |
| - extend |
| - from |
| - getComponents |
| - getKey |
| - getLabel |
| - getLinkUrl |
| - getNamespace |
| - getPath |
| - getShortValue |
| - getType |
| - getValue |
| - hashCode |
| - include |
| - inferType |
| - item |
| - items |
| - none |
| - of |
| - root |
| - setKey |
| - setLabel |
| - setLinkUrl |
| - setNamespace |
| - setShortValue |
| - setType |
| - setValue |
| - toString |
| - withLabel |
| - withLinkUrl |
| - withNamespace |
| Distinct: |
| methods: |
| - accumulationMode |
| - apply |
| - create |
| - expand |
| - named |
| - of |
| - output |
| - processElement |
| - projected |
| - triggeredBy |
| - windowBy |
| - withAllowedLateness |
| - withOnTimeBehavior |
| - withRepresentativeType |
| - withRepresentativeValueFn |
| - withTimestampCombiner |
| DistributionResult: |
| methods: |
| - create |
| - getCount |
| - getMax |
| - getMean |
| - getMin |
| - getSum |
| properties: |
| - IDENTITY_ELEMENT |
| DlqProvider: |
| methods: |
| - expand |
| - identifier |
| - newDlqTransform |
| DoFn: |
| methods: |
| - element |
| - fireTimestamp |
| - getAllowedTimestampSkew |
| - getInputTypeDescriptor |
| - getOutputTypeDescriptor |
| - getPipelineOptions |
| - output |
| - outputWithTimestamp |
| - pane |
| - populateDisplayData |
| - prepareForProcessing |
| - resume |
| - resumeDelay |
| - shouldResume |
| - sideInput |
| - stop |
| - timeDomain |
| - timestamp |
| - window |
| - withResumeDelay |
| DoFnInfo: |
| methods: |
| - forFn |
| - getDoFn |
| - getDoFnSchemaInformation |
| - getInputCoder |
| - getMainOutput |
| - getOutputCoders |
| - getSideInputMapping |
| - getSideInputViews |
| - getWindowingStrategy |
| - withFn |
| DoFnInvokers: |
| methods: |
| - getErrorContext |
| - invokerFor |
| - pipelineOptions |
| - tryInvokeSetupFor |
| DoFnOutputReceivers: |
| methods: |
| - get |
| - getRowReceiver |
| - output |
| - outputWithTimestamp |
| - rowReceiver |
| - windowedMultiReceiver |
| - windowedReceiver |
| DoFnSchemaInformation: |
| methods: |
| - apply |
| - create |
| - getElementConverters |
| - getFieldAccessDescriptor |
| - of |
| - toBuilder |
| DoFnSignature: |
| methods: |
| - alwaysFetched |
| - boundedWindow |
| - build |
| - bundleFinalizer |
| - coderT |
| - dispatch |
| - elementParameter |
| - elementT |
| - estimatorStateT |
| - estimatorT |
| - extraParameters |
| - field |
| - fieldAccessDeclarations |
| - fieldAccessString |
| - finishBundle |
| - finishBundleContext |
| - fnClass |
| - getInitialRestriction |
| - getInitialWatermarkEstimatorState |
| - getMainOutputReceiver |
| - getRestrictionCoder |
| - getSchemaElementParameters |
| - getSideInputParameters |
| - getSize |
| - getWatermarkEstimatorStateCoder |
| - hasReturnValue |
| - id |
| - index |
| - isBoundedPerElement |
| - isRowReceiver |
| - isSplittable |
| - isStateful |
| - keyT |
| - match |
| - newTracker |
| - newWatermarkEstimator |
| - onTimerContext |
| - onTimerFamilyMethods |
| - onTimerMethods |
| - onWindowExpiration |
| - onWindowExpirationContext |
| - outputReceiverParameter |
| - paneInfoParameter |
| - pipelineOptions |
| - processContext |
| - processElement |
| - referent |
| - requiresStableInput |
| - requiresTimeSortedInput |
| - restrictionParameter |
| - restrictionT |
| - restrictionTracker |
| - schemaElementParameter |
| - setElementT |
| - setFieldAccessString |
| - setIndex |
| - setSideInputId |
| - setup |
| - sideInputId |
| - sideInputParameter |
| - splitRestriction |
| - startBundle |
| - startBundleContext |
| - stateDeclarations |
| - stateParameter |
| - stateType |
| - taggedOutputReceiverParameter |
| - targetMethod |
| - teardown |
| - timeDomainParameter |
| - timerDeclarations |
| - timerFamilyDeclarations |
| - timerFamilyParameter |
| - timerIdParameter |
| - timerParameter |
| - timestampParameter |
| - toBuilder |
| - trackerT |
| - truncateRestriction |
| - usesState |
| - usesTimers |
| - watermarkEstimator |
| - watermarkEstimatorState |
| - watermarkEstimatorStateT |
| - watermarkEstimatorT |
| - windowT |
| properties: |
| - PREFIX |
| DoFnSignatures: |
| methods: |
| - addFieldAccessDeclaration |
| - addFieldAccessDeclarations |
| - addParameter |
| - addStateDeclaration |
| - addStateDeclarations |
| - addTimerDeclaration |
| - addTimerDeclarations |
| - addTimerFamilyDeclaration |
| - addTimerFamilyDeclarations |
| - checkArgument |
| - checkNotNull |
| - create |
| - findParameter |
| - findParameters |
| - getAnnotations |
| - getExtraParameters |
| - getFieldAccessDeclarations |
| - getIndex |
| - getMethod |
| - getSignature |
| - getStateDeclarations |
| - getStateParameters |
| - getStateSpecOrThrow |
| - getTimerDeclarations |
| - getTimerFamilyDeclarations |
| - getTimerFamilyParameters |
| - getTimerFamilySpecOrThrow |
| - getTimerParameters |
| - getTimerSpecOrThrow |
| - getType |
| - hasParameter |
| - isSplittable |
| - isStateful |
| - of |
| - requiresTimeSortedInput |
| - setParameter |
| - signatureForDoFn |
| - usesBagState |
| - usesBundleFinalizer |
| - usesMapState |
| - usesMultimapState |
| - usesOrderedListState |
| - usesSetState |
| - usesState |
| - usesTimers |
| - usesValueState |
| - usesWatermarkHold |
| DoFnTester: |
| methods: |
| - clearOutputElements |
| - close |
| - createProcessContext |
| - dispatch |
| - element |
| - finishBundle |
| - finishBundleContext |
| - get |
| - getCloningBehavior |
| - getErrorContext |
| - getMainOutputTag |
| - getMutableOutput |
| - getPipelineOptions |
| - key |
| - of |
| - output |
| - outputReceiver |
| - outputWithTimestamp |
| - pane |
| - paneInfo |
| - peekOutputElements |
| - peekOutputElementsInWindow |
| - peekOutputElementsWithTimestamp |
| - pipelineOptions |
| - processBundle |
| - processContext |
| - processElement |
| - processTimestampedElement |
| - processWindowedElement |
| - restriction |
| - restrictionTracker |
| - setCloningBehavior |
| - setSideInput |
| - setSideInputs |
| - sideInput |
| - startBundle |
| - startBundleContext |
| - taggedOutputReceiver |
| - takeOutputElements |
| - takeOutputElementsWithTimestamp |
| - timeDomain |
| - timerId |
| - timestamp |
| - window |
| DoFnWithExecutionInformation: |
| methods: |
| - getDoFn |
| - getMainOutputTag |
| - getSchemaInformation |
| - getSideInputMapping |
| - of |
| Done: |
| methods: |
| - decode |
| - encode |
| - equals |
| - hashCode |
| - sizeInBytes |
| - structuralValue |
| - toString |
| - verifyDeterministic |
| properties: |
| - CODER |
| DoubleCoder: |
| methods: |
| - consistentWithEquals |
| - decode |
| - encode |
| - getEncodedTypeDescriptor |
| - isRegisterByteSizeObserverCheap |
| - of |
| - verifyDeterministic |
| DropFields: |
| methods: |
| - expand |
| - fields |
| DurationCoder: |
| methods: |
| - consistentWithEquals |
| - decode |
| - encode |
| - getEncodedTypeDescriptor |
| - isRegisterByteSizeObserverCheap |
| - of |
| - registerByteSizeObserver |
| - verifyDeterministic |
| DynamicAvroDestinations: |
| methods: |
| - getCodec |
| - getDatumWriterFactory |
| - getMetadata |
| - getSchema |
| DynamicDestinations: |
| methods: |
| - getDestination |
| - getDestinationCoder |
| - getSchema |
| - getSideInputs |
| - getTable |
| - sideInput |
| DynamicFileDestinations: |
| methods: |
| - constant |
| - formatRecord |
| - getDefaultDestination |
| - getDestination |
| - getDestinationCoder |
| - getFilenamePolicy |
| - populateDisplayData |
| - toDefaultPolicies |
| DynamicProtoCoder: |
| methods: |
| - coderFor |
| - equals |
| - getCoderProvider |
| - hashCode |
| - of |
| - withExtensionsFrom |
| properties: |
| - serialVersionUID |
| DynamoDBIO: |
| methods: |
| - apply |
| - build |
| - builder |
| - create |
| - expand |
| - finishBundle |
| - items |
| - processElement |
| - read |
| - setMaxAttempts |
| - setMaxDuration |
| - setup |
| - startBundle |
| - tearDown |
| - test |
| - withAwsClientsProvider |
| - withClientConfiguration |
| - withCoder |
| - withDeduplicateKeys |
| - withDynamoDbClientProvider |
| - withRetryConfiguration |
| - withScanRequestFn |
| - withScanResponseMapperFn |
| - withScanResultMapperFn |
| - withWriteRequestMapperFn |
| - write |
| ElasticsearchIO: |
| methods: |
| - advance |
| - bulkIO |
| - close |
| - closeClient |
| - create |
| - createReader |
| - customizeRequestConfig |
| - decode |
| - docToBulk |
| - encode |
| - expand |
| - finishBundle |
| - fromSpec |
| - getAddresses |
| - getAllowedTimestampSkew |
| - getApiKey |
| - getApiPrefix |
| - getBearerToken |
| - getBulkDirective |
| - getBulkEndPoint |
| - getBulkIO |
| - getConnectTimeout |
| - getCountEndPoint |
| - getCurrent |
| - getCurrentSource |
| - getDocToBulk |
| - getEstimatedSizeBytes |
| - getHasError |
| - getIndex |
| - getInputDoc |
| - getKeystorePassword |
| - getKeystorePath |
| - getOutputCoder |
| - getPassword |
| - getPrefixedEndpoint |
| - getResponseItemJson |
| - getSearchEndPoint |
| - getSocketTimeout |
| - getTimestamp |
| - getType |
| - getUsername |
| - isTrustSelfSignedCerts |
| - of |
| - output |
| - populateDisplayData |
| - processElement |
| - read |
| - serialize |
| - setup |
| - split |
| - start |
| - startBundle |
| - test |
| - validate |
| - withAllowableResponseErrors |
| - withApiKey |
| - withAppendOnly |
| - withBackendVersion |
| - withBatchSize |
| - withBearerToken |
| - withBulkDirective |
| - withConnectTimeout |
| - withConnectionConfiguration |
| - withDocVersionFn |
| - withDocVersionType |
| - withHasError |
| - withIdFn |
| - withIgnoreVersionConflicts |
| - withIndexFn |
| - withInputDoc |
| - withIsDeleteFn |
| - withKeystorePassword |
| - withKeystorePath |
| - withMaxBatchSize |
| - withMaxBatchSizeBytes |
| - withMaxBufferingDuration |
| - withMaxParallelRequests |
| - withMaxParallelRequestsPerWindow |
| - withMetadata |
| - withPassword |
| - withQuery |
| - withResponseItemJson |
| - withRetryConfiguration |
| - withRoutingFn |
| - withScrollKeepalive |
| - withSocketTimeout |
| - withThrowWriteErrors |
| - withTimestamp |
| - withTrustSelfSignedCerts |
| - withTypeFn |
| - withUpsertScript |
| - withUsePartialUpdate |
| - withUseStatefulBatches |
| - withUsername |
| - write |
| properties: |
| - FAILED_WRITES |
| - SUCCESSFUL_WRITES |
| ElementByteSizeObservableIterable: |
| methods: |
| - addObserver |
| - iterator |
| ElementByteSizeObservableIterator: {} |
| ElementByteSizeObserver: |
| methods: |
| - advance |
| - getIsLazy |
| - setLazy |
| - setScalingFactor |
| - update |
| EmptyOnDeserializationThreadLocal: {} |
| EncodableThrowable: |
| methods: |
| - equals |
| - forThrowable |
| - hashCode |
| - throwable |
| EncodedBoundedWindow: |
| methods: |
| - consistentWithEquals |
| - decode |
| - encode |
| - forEncoding |
| - getEncodedWindow |
| - isRegisterByteSizeObserverCheap |
| - maxTimestamp |
| properties: |
| - INSTANCE |
| EncodingException: {} |
| EntityToRow: |
| methods: |
| - create |
| - expand |
| - processElement |
| EnumerationType: |
| methods: |
| - create |
| - equals |
| - getArgument |
| - getArgumentType |
| - getBaseType |
| - getIdentifier |
| - getValue |
| - getValues |
| - getValuesMap |
| - hashCode |
| - toBaseType |
| - toInputType |
| - toString |
| - valueOf |
| properties: |
| - IDENTIFIER |
| Event: |
| methods: |
| - decode |
| - encode |
| - equals |
| - hasAnnotation |
| - hashCode |
| - sizeInBytes |
| - structuralValue |
| - toString |
| - verifyDeterministic |
| - withAnnotation |
| properties: |
| - CODER |
| - bid |
| - newAuction |
| - newPerson |
| ExecutionStateSampler: |
| methods: |
| - activate |
| - create |
| - deactivate |
| - getCurrentThreadsPTransformId |
| - getLastTransitionTimeMillis |
| - getPTransformId |
| - getPTransformUniqueName |
| - getStatus |
| - getTrackedThread |
| - reset |
| - start |
| - stop |
| - takeSample |
| - updateFinalMonitoringData |
| - updateIntermediateMonitoringData |
| - updateMonitoringData |
| ExecutionStateSamplerBenchmark: |
| methods: |
| - setup |
| - tearDown |
| - testLargeBundleHarnessStateSampler |
| - testLargeBundleRunnersCoreStateSampler |
| - testTinyBundleHarnessStateSampler |
| - testTinyBundleRunnersCoreStateSampler |
| properties: |
| - sampler |
| - state1 |
| - state2 |
| - state3 |
| - tracker |
| ExpansionServer: |
| methods: |
| - close |
| - create |
| - getHost |
| - getPort |
| ExpansionService: |
| methods: |
| - close |
| - discoverSchemaTransform |
| - expand |
| - fromOptions |
| - getDependencies |
| - getTransform |
| - knownTransforms |
| - main |
| - payloadToConfig |
| - run |
| ExpansionServiceSchemaTransformProvider: |
| methods: |
| - createInput |
| - extractOutputs |
| - getTransform |
| - of |
| ExplicitShardedFile: |
| methods: |
| - readFilesWithRetries |
| - toString |
| ExposedByteArrayInputStream: |
| methods: |
| - close |
| - readAll |
| ExposedByteArrayOutputStream: |
| methods: |
| - reset |
| - toByteArray |
| - write |
| - writeAndOwn |
| ExpressionConverter: |
| methods: |
| - convertRelNodeToRexRangeRef |
| - convertResolvedLiteral |
| - convertRexNodeFromResolvedExpr |
| - convertTableValuedFunction |
| - indexOfProjectionColumnRef |
| - retrieveRexNode |
| - retrieveRexNodeFromOrderByScan |
| - trueLiteral |
| ExternalRead: |
| methods: |
| - buildExternal |
| - knownBuilders |
| - setIdLabel |
| - setSubscription |
| - setTimestampAttribute |
| - setTopic |
| - setWithAttributes |
| properties: |
| - URN |
| ExternalSchemaIOTransformRegistrar: |
| methods: |
| - buildExternal |
| - knownBuilderInstances |
| - setConfig |
| - setDataSchema |
| - setLocation |
| ExternalSorter: |
| methods: |
| - create |
| - getMemoryMB |
| - getSorterType |
| - getTempLocation |
| - setMemoryMB |
| - setSorterType |
| - setTempLocation |
| ExternalSqlTransformRegistrar: |
| methods: |
| - buildExternal |
| - knownBuilders |
| - setDialect |
| - setQuery |
| ExternalTransformRegistrarImpl: |
| methods: |
| - knownBuilderInstances |
| properties: |
| - READ_URN |
| - WRITE_URN |
| ExternalWorkerService: |
| methods: |
| - close |
| - main |
| - start |
| - startWorker |
| - stopWorker |
| ExternalWrite: |
| methods: |
| - buildExternal |
| - knownBuilders |
| - setIdLabel |
| - setTimestampAttribute |
| - setTopic |
| properties: |
| - URN |
| FailsafeValueInSingleWindow: |
| methods: |
| - decode |
| - encode |
| - getCoderArguments |
| - getComponents |
| - getFailsafeValue |
| - getPane |
| - getTimestamp |
| - getValue |
| - getWindow |
| - of |
| - verifyDeterministic |
| Failure: |
| methods: |
| - build |
| - getError |
| - getPayload |
| - newBuilder |
| - setError |
| - setPayload |
| FailureCollectorWrapper: |
| methods: |
| - addFailure |
| - getOrThrowException |
| - getValidationFailures |
| FakeBigQueryServices: |
| methods: |
| - cancel |
| - convertNumbers |
| - decodeQueryResult |
| - encodeQueryResult |
| - getDatasetService |
| - getJobService |
| - getStorageClient |
| - iterator |
| - withDatasetService |
| - withJobService |
| - withStorageClient |
| FakeDatasetService: |
| methods: |
| - appendRows |
| - close |
| - commitWriteStreams |
| - createDataset |
| - createTable |
| - createWriteStream |
| - deleteDataset |
| - deleteTable |
| - failOnInsert |
| - finalizeWriteStream |
| - flush |
| - getAllIds |
| - getAllRows |
| - getDataset |
| - getInsertCount |
| - getStreamAppendClient |
| - getTable |
| - getTableImpl |
| - insertAll |
| - isTableEmpty |
| - patchTableDescription |
| - pin |
| - setShouldFailRow |
| - setUp |
| - unpin |
| - updateTableSchema |
| FakeJobService: |
| methods: |
| - close |
| - dryRunQuery |
| - expectDryRunQuery |
| - getAllJobs |
| - getJob |
| - getNumExtractJobCalls |
| - pollJob |
| - setNumFailuresExpected |
| - setUp |
| - startCopyJob |
| - startExtractJob |
| - startLoadJob |
| - startQueryJob |
| FhirBundleParameter: |
| methods: |
| - getBundle |
| - getMetadata |
| - of |
| FhirBundleResponse: |
| methods: |
| - getFhirBundleParameter |
| - getResponse |
| - of |
| FhirIO: |
| methods: |
| - addToFile |
| - closeFile |
| - deidentify |
| - delete |
| - executeBundles |
| - expand |
| - exportResources |
| - fhirStoresImport |
| - finishSpecifyingOutput |
| - getFailedBodies |
| - getFailedBundles |
| - getFailedFiles |
| - getFailedReads |
| - getFailedSearches |
| - getFhirStore |
| - getKeyedResources |
| - getPatientEverything |
| - getPipeline |
| - getResources |
| - getSuccessfulBodies |
| - getSuccessfulBundles |
| - importBatch |
| - importResources |
| - in |
| - init |
| - initBatch |
| - initClient |
| - initFile |
| - instantiateHealthcareClient |
| - process |
| - processElement |
| - readResources |
| - searchResources |
| - searchResourcesWithGenericParameters |
| properties: |
| - DEAD_LETTER |
| - FAILED_BODY |
| - FAILED_BUNDLES |
| - FAILED_FILES |
| - OUT |
| - SUCCESSFUL_BODY |
| - SUCCESSFUL_BUNDLES |
| - TEMP_FILES |
| FhirIOPatientEverything: |
| methods: |
| - expand |
| - finishSpecifyingOutput |
| - getFailedReads |
| - getPatientCompartments |
| - getPipeline |
| - instantiateHealthcareClient |
| - processElement |
| properties: |
| - DEAD_LETTER |
| - OUT |
| FhirSearchParameter: |
| methods: |
| - equals |
| - getKey |
| - getQueries |
| - getResourceType |
| - hashCode |
| - of |
| - toString |
| FhirSearchParameterCoder: |
| methods: |
| - decode |
| - encode |
| - of |
| FieldAccessDescriptor: |
| methods: |
| - build |
| - builder |
| - create |
| - fieldIdsAccessed |
| - fieldNamesAccessed |
| - getAllFields |
| - getFieldId |
| - getFieldName |
| - getFieldRename |
| - getFieldsAccessed |
| - getKind |
| - getList |
| - getMap |
| - getNestedFieldsAccessed |
| - getQualifiers |
| - nestedFieldsById |
| - nestedFieldsByName |
| - of |
| - referencesSingleField |
| - resolve |
| - setFieldId |
| - setFieldName |
| - setFieldRename |
| - setQualifiers |
| - toString |
| - union |
| - withAllFields |
| - withFieldIds |
| - withFieldNameAs |
| - withFieldNames |
| - withFieldNamesAs |
| - withFields |
| - withNestedField |
| - withNestedFieldAs |
| FieldAccessDescriptorParser: |
| methods: |
| - getQualifiers |
| - parse |
| - visitArrayQualifierList |
| - visitDotExpression |
| - visitFieldSpecifier |
| - visitMapQualifierList |
| - visitQualifiedComponent |
| - visitQualifyComponent |
| - visitSimpleIdentifier |
| - visitWildcard |
| FieldTypeDescriptors: |
| methods: |
| - fieldTypeForJavaType |
| - javaTypeForFieldType |
| FieldValueTypeInformation: |
| methods: |
| - forField |
| - forGetter |
| - forOneOf |
| - forSetter |
| - getElementType |
| - getField |
| - getMapKeyType |
| - getMapValueType |
| - getMethod |
| - getName |
| - getNameOverride |
| - getNumber |
| - getNumberOverride |
| - getOneOfTypes |
| - getRawType |
| - getType |
| - isNullable |
| - setElementType |
| - setField |
| - setMapKeyType |
| - setMapValueType |
| - setMethod |
| - setName |
| - setNullable |
| - setNumber |
| - setOneOfTypes |
| - setRawType |
| - setType |
| - withName |
| FileBasedSink: |
| methods: |
| - apply |
| - cleanup |
| - close |
| - convertToFileResourceIfPossible |
| - create |
| - createWriteOperation |
| - createWriter |
| - decode |
| - encode |
| - formatRecord |
| - fromCanonical |
| - getCoderArguments |
| - getComponents |
| - getDefaultDestination |
| - getDestination |
| - getDestinationCoder |
| - getDestinationFile |
| - getDynamicDestinations |
| - getFilenamePolicy |
| - getMimeType |
| - getOutputFile |
| - getPaneInfo |
| - getShard |
| - getSideInputs |
| - getSink |
| - getSuggestedFilenameSuffix |
| - getTempDirectory |
| - getTempDirectoryProvider |
| - getTempFilename |
| - getWindow |
| - getWriteOperation |
| - of |
| - open |
| - populateDisplayData |
| - removeTemporaryFiles |
| - setWindowedWrites |
| - sideInput |
| - toString |
| - unwindowedFilename |
| - validate |
| - verifyDeterministic |
| - windowedFilename |
| - withShard |
| - write |
| FileBasedSource: |
| methods: |
| - advance |
| - allowsDynamicSplitting |
| - close |
| - createReader |
| - createSourceForSubrange |
| - getCurrent |
| - getCurrentSource |
| - getCurrentTimestamp |
| - getEmptyMatchTreatment |
| - getEstimatedSizeBytes |
| - getFileOrPatternSpec |
| - getFileOrPatternSpecProvider |
| - getFractionConsumed |
| - getMaxEndOffset |
| - getMode |
| - getSingleFileMetadata |
| - populateDisplayData |
| - split |
| - splitAtFraction |
| - start |
| - toString |
| - validate |
| FileChecksumMatcher: |
| methods: |
| - describeMismatchSafely |
| - describeTo |
| - fileContentsHaveChecksum |
| - matchesSafely |
| FileIO: |
| methods: |
| - apply |
| - by |
| - continuously |
| - create |
| - createWriteOperation |
| - createWriter |
| - defaultNaming |
| - equals |
| - expand |
| - filepattern |
| - formatRecord |
| - getCompression |
| - getDefaultDestination |
| - getDestination |
| - getDestinationCoder |
| - getEmptyMatchTreatment |
| - getFilenamePolicy |
| - getMatchUpdatedFiles |
| - getMetadata |
| - getSideInputs |
| - getWatchInterval |
| - hashCode |
| - match |
| - matchAll |
| - open |
| - openSeekable |
| - populateDisplayData |
| - process |
| - readFullyAsBytes |
| - readFullyAsUTF8String |
| - readMatches |
| - relativeFileNaming |
| - sideInput |
| - to |
| - toString |
| - unwindowedFilename |
| - via |
| - windowedFilename |
| - withCompression |
| - withConfiguration |
| - withDestinationCoder |
| - withDirectoryTreatment |
| - withEmptyGlobalWindowDestination |
| - withEmptyMatchTreatment |
| - withIgnoreWindowing |
| - withNaming |
| - withNoSpilling |
| - withNumShards |
| - withPrefix |
| - withSharding |
| - withSuffix |
| - withTempDirectory |
| - write |
| - writeDynamic |
| FilePatternMatchingShardedFile: |
| methods: |
| - readFilesWithRetries |
| - toString |
| FileSystem: {} |
| FileSystemUtils: |
| methods: |
| - wildcardToRegexp |
| FileSystems: |
| methods: |
| - apply |
| - copy |
| - create |
| - delete |
| - hasGlobWildcard |
| - match |
| - matchNewResource |
| - matchResources |
| - matchSingleFileSpec |
| - open |
| - rename |
| - setDefaultPipelineOptions |
| properties: |
| - DEFAULT_SCHEME |
| - filteredExistingSrcs |
| - resultDestinations |
| - resultSources |
| FileWriteSchemaTransformConfiguration: |
| methods: |
| - build |
| - builder |
| - csvConfigurationBuilder |
| - getCharset |
| - getCompression |
| - getCompressionCodecName |
| - getCsvConfiguration |
| - getCsvFormat |
| - getFilenamePrefix |
| - getFilenameSuffix |
| - getFormat |
| - getNumShards |
| - getParquetConfiguration |
| - getPreamble |
| - getRootElement |
| - getRowGroupSize |
| - getShardNameTemplate |
| - getXmlConfiguration |
| - parquetConfigurationBuilder |
| - setCharset |
| - setCompression |
| - setCompressionCodecName |
| - setCsvConfiguration |
| - setCsvFormat |
| - setFilenamePrefix |
| - setFilenameSuffix |
| - setFormat |
| - setNumShards |
| - setParquetConfiguration |
| - setPreamble |
| - setRootElement |
| - setRowGroupSize |
| - setShardNameTemplate |
| - setXmlConfiguration |
| - xmlConfigurationBuilder |
| FileWriteSchemaTransformFormatProviders: |
| methods: |
| - buildTransform |
| - identifier |
| - loadProviders |
| FillGaps: |
| methods: |
| - expand |
| - getNextWindow |
| - getPreviousWindow |
| - getValue |
| - keepEarliest |
| - keepLatest |
| - of |
| - onGcTimer |
| - onTimer |
| - process |
| Filter: |
| methods: |
| - by |
| - create |
| - equal |
| - expand |
| - getPredicate |
| - getRowSelector |
| - greaterThan |
| - greaterThanEq |
| - lessThan |
| - lessThanEq |
| - named |
| - of |
| - output |
| - populateDisplayData |
| - process |
| - processElement |
| - whereFieldId |
| - whereFieldIds |
| - whereFieldName |
| - whereFieldNames |
| FinalizeBundleHandler: |
| methods: |
| - create |
| - finalizeBundle |
| - getCallback |
| - getExpiryTime |
| - registerCallbacks |
| FindQuery: |
| methods: |
| - apply |
| - create |
| - withFilters |
| - withLimit |
| - withProjection |
| FirestoreIO: |
| methods: |
| - v1 |
| FirestoreV1: |
| methods: |
| - apply |
| - batchGetDocuments |
| - batchWrite |
| - build |
| - equals |
| - expand |
| - getNumBytes |
| - getNumWrites |
| - getStatus |
| - getWrite |
| - getWriteFailures |
| - getWriteResult |
| - hashCode |
| - listCollectionIds |
| - listDocuments |
| - partitionQuery |
| - populateDisplayData |
| - processElement |
| - read |
| - runQuery |
| - toBuilder |
| - toString |
| - withDeadLetterQueue |
| - withNameOnlyQuery |
| - withReadTime |
| - withRpcQosOptions |
| - write |
| FixedBytes: |
| methods: |
| - getLength |
| - getName |
| - of |
| - toBaseType |
| - toInputType |
| - toString |
| properties: |
| - IDENTIFIER |
| FixedPrecisionNumeric: |
| methods: |
| - of |
| - toInputType |
| properties: |
| - BASE_IDENTIFIER |
| - IDENTIFIER |
| FixedString: |
| methods: |
| - getLength |
| - getName |
| - of |
| - toInputType |
| - toString |
| properties: |
| - IDENTIFIER |
| FixedWindows: |
| methods: |
| - assignWindow |
| - equals |
| - getOffset |
| - getSize |
| - hashCode |
| - isCompatible |
| - of |
| - populateDisplayData |
| - verifyCompatibility |
| - windowCoder |
| - withOffset |
| FlatMap: |
| methods: |
| - eventTimeBy |
| - getAllowedTimestampSkew |
| - getEventTimeExtractor |
| - getFunctor |
| - named |
| - of |
| - output |
| - using |
| FlatMapElements: |
| methods: |
| - exceptionsInto |
| - exceptionsVia |
| - expand |
| - getInputTypeDescriptor |
| - getOutputTypeDescriptor |
| - getTypeDescriptor |
| - into |
| - populateDisplayData |
| - processElement |
| - via |
| FlatMapTranslator: |
| methods: |
| - collect |
| - getAllowedTimestampSkew |
| - processElement |
| - translate |
| Flatten: |
| methods: |
| - apply |
| - expand |
| - iterables |
| - pCollections |
| FlattenRunner: |
| methods: |
| - createRunnerForPTransform |
| - getPTransformRunnerFactories |
| FloatCoder: |
| methods: |
| - consistentWithEquals |
| - decode |
| - encode |
| - getEncodedTypeDescriptor |
| - isRegisterByteSizeObserverCheap |
| - of |
| - verifyDeterministic |
| FluentBackoff: |
| methods: |
| - backoff |
| - nextBackOffMillis |
| - reset |
| - toString |
| - withExponent |
| - withInitialBackoff |
| - withMaxBackoff |
| - withMaxCumulativeBackoff |
| - withMaxRetries |
| properties: |
| - DEFAULT |
| FnApiDoFnRunner: |
| methods: |
| - accept |
| - align |
| - bundleFinalizer |
| - clear |
| - createRunnerForPTransform |
| - element |
| - finishBundleContext |
| - fireTimestamp |
| - forRoots |
| - get |
| - getCurrentRelativeTime |
| - getDownstreamSplit |
| - getErrorContext |
| - getNewWindowStopIndex |
| - getPTransformRunnerFactories |
| - getPipelineOptions |
| - getPrimaryInFullyProcessedWindowsRoot |
| - getPrimarySplitRoot |
| - getProgress |
| - getResidualInUnprocessedWindowsRoot |
| - getResidualSplitRoot |
| - getWindowSplit |
| - key |
| - of |
| - offset |
| - onClaimFailed |
| - onClaimed |
| - onTimerContext |
| - output |
| - outputReceiver |
| - outputRowReceiver |
| - outputWithTimestamp |
| - pane |
| - paneInfo |
| - pipelineOptions |
| - processContext |
| - reset |
| - restriction |
| - restrictionTracker |
| - schemaElement |
| - set |
| - setRelative |
| - sideInput |
| - startBundleContext |
| - state |
| - taggedOutputReceiver |
| - timeDomain |
| - timer |
| - timerFamily |
| - timerId |
| - timestamp |
| - trySplit |
| - updateFinalMonitoringData |
| - updateIntermediateMonitoringData |
| - watermarkEstimator |
| - watermarkEstimatorState |
| - window |
| - withNoOutputTimestamp |
| - withOutputTimestamp |
| FnApiStateAccessor: |
| methods: |
| - add |
| - addAccum |
| - addIfAbsent |
| - apply |
| - bindBag |
| - bindCombining |
| - bindCombiningWithContext |
| - bindMap |
| - bindMultimap |
| - bindOrderedList |
| - bindSet |
| - bindValue |
| - bindWatermark |
| - clear |
| - computeIfAbsent |
| - contains |
| - entries |
| - finalizeState |
| - get |
| - getAccum |
| - getOrDefault |
| - getPipelineOptions |
| - isEmpty |
| - keys |
| - mergeAccumulators |
| - put |
| - read |
| - readLater |
| - remove |
| - sideInput |
| - values |
| - window |
| - write |
| FnApiTimerBundleTracker: |
| methods: |
| - get |
| - getBundleModifications |
| - getModifiedEventTimersOrdered |
| - getModifiedProcessingTimersOrdered |
| - getModifiedSynchronizedProcessingTimersOrdered |
| - getModifiedTimerIds |
| - getModifiedTimersOrdered |
| - getTimeDomain |
| - getTimer |
| - getTimerFamilyOrId |
| - of |
| - outputTimers |
| - reset |
| - timerModified |
| FnHarness: |
| methods: |
| - apply |
| - main |
| Fold: |
| methods: |
| - of |
| ForwardingClientResponseObserver: |
| methods: |
| - beforeStart |
| - create |
| - onCompleted |
| - onError |
| - onNext |
| FullJoin: |
| methods: |
| - by |
| - named |
| - of |
| - using |
| FullNameTableProvider: |
| methods: |
| - buildBeamSqlTable |
| - getSubProvider |
| - getTable |
| - getTableByFullName |
| - getTableType |
| - registerKnownTableNames |
| GaugeResult: |
| methods: |
| - create |
| - empty |
| - getTimestamp |
| - getValue |
| GceMetadataUtil: |
| methods: |
| - fetchDataflowJobId |
| GcpCredentialFactory: |
| methods: |
| - fromOptions |
| - getCredential |
| GcpIoPipelineOptionsRegistrar: |
| methods: |
| - getPipelineOptions |
| GcpPipelineOptionsRegistrar: |
| methods: |
| - getPipelineOptions |
| GcsCreateOptions: |
| methods: |
| - build |
| - builder |
| - gcsUploadBufferSizeBytes |
| - setGcsUploadBufferSizeBytes |
| GcsFileSystemRegistrar: |
| methods: |
| - fromOptions |
| GcsPath: |
| methods: |
| - compareTo |
| - endsWith |
| - equals |
| - fromComponents |
| - fromObject |
| - fromResourceName |
| - fromUri |
| - getBucket |
| - getFileName |
| - getFileSystem |
| - getName |
| - getNameCount |
| - getObject |
| - getParent |
| - getRoot |
| - hasNext |
| - hashCode |
| - isAbsolute |
| - iterator |
| - next |
| - normalize |
| - register |
| - relativize |
| - remove |
| - resolve |
| - resolveSibling |
| - setFileSystem |
| - startsWith |
| - subpath |
| - toAbsolutePath |
| - toFile |
| - toRealPath |
| - toResourceName |
| - toString |
| - toUri |
| properties: |
| - GCS_URI |
| - SCHEME |
| GcsPathValidator: |
| methods: |
| - fromOptions |
| - validateInputFilePatternSupported |
| - validateOutputFilePrefixSupported |
| - validateOutputResourceSupported |
| - verifyPath |
| GcsResourceId: |
| methods: |
| - equals |
| - getCurrentDirectory |
| - getFilename |
| - getScheme |
| - hashCode |
| - isDirectory |
| - resolve |
| - toString |
| GcsUtil: |
| methods: |
| - bucketAccessible |
| - bucketOwner |
| - build |
| - builder |
| - copy |
| - create |
| - createBucket |
| - enqueue |
| - execute |
| - expand |
| - fileSize |
| - getContentType |
| - getExpectFileToNotExist |
| - getFrom |
| - getLastError |
| - getNonWildcardPrefix |
| - getObject |
| - getObjects |
| - getReadyToEnqueue |
| - getTo |
| - getUploadBufferSizeBytes |
| - ioException |
| - isWildcard |
| - listObjects |
| - onFailure |
| - onSuccess |
| - open |
| - queue |
| - remove |
| - rename |
| - setContentType |
| - setExpectFileToNotExist |
| - setUploadBufferSizeBytes |
| - shouldRetry |
| - size |
| - storageObject |
| - verifyBucketAccessible |
| GenerateSequence: |
| methods: |
| - buildExternal |
| - expand |
| - from |
| - knownBuilders |
| - populateDisplayData |
| - setElementsPerPeriod |
| - setMaxReadTime |
| - setPeriod |
| - setStart |
| - setStop |
| - to |
| - withMaxReadTime |
| - withRate |
| - withTimestampFn |
| properties: |
| - URN |
| GenerateSequenceTableProvider: |
| methods: |
| - buildBeamSqlTable |
| - getTableType |
| Generator: |
| methods: |
| - compareTo |
| - copy |
| - currentInterEventDelayUs |
| - equals |
| - getCurrentConfig |
| - getFractionConsumed |
| - getNextEventId |
| - hasNext |
| - hashCode |
| - next |
| - nextEvent |
| - remove |
| - splitAtEventId |
| - toCheckpoint |
| - toString |
| - withDelay |
| properties: |
| - event |
| - eventTimestamp |
| - wallclockTimestamp |
| - watermark |
| GeneratorCheckpoint: |
| methods: |
| - decode |
| - encode |
| - finalizeCheckpoint |
| - toGenerator |
| - toString |
| - verifyDeterministic |
| properties: |
| - CODER_INSTANCE |
| GeneratorConfig: |
| methods: |
| - copy |
| - copyWith |
| - estimatedBytesForEvents |
| - getAvgAuctionByteSize |
| - getAvgBidByteSize |
| - getAvgPersonByteSize |
| - getEstimatedSizeBytes |
| - getHotAuctionRatio |
| - getHotBiddersRatio |
| - getHotSellersRatio |
| - getNumActivePeople |
| - getNumInFlightAuctions |
| - getOccasionalDelaySec |
| - getProbDelayedEvent |
| - getStartEventId |
| - getStopEventId |
| - nextAdjustedEventNumber |
| - nextEventNumber |
| - nextEventNumberForWatermark |
| - split |
| - timestampAndInterEventDelayUsForEvent |
| - toString |
| properties: |
| - AUCTION_PROPORTION |
| - FIRST_AUCTION_ID |
| - FIRST_CATEGORY_ID |
| - FIRST_PERSON_ID |
| - PERSON_PROPORTION |
| - PROPORTION_DENOMINATOR |
| - baseTime |
| - firstEventId |
| - firstEventNumber |
| - maxEvents |
| GenericDlq: |
| methods: |
| - getDlqTransform |
| GenericTranslatorProvider: |
| methods: |
| - build |
| - createWithDefaultTranslators |
| - findTranslator |
| - newBuilder |
| - register |
| GetterBasedSchemaProvider: |
| methods: |
| - apply |
| - create |
| - equals |
| - fieldValueGetters |
| - fieldValueTypeInformations |
| - fromRowFunction |
| - get |
| - getRaw |
| - hashCode |
| - name |
| - schemaTypeCreator |
| - toRowFunction |
| GetterBasedSchemaProviderBenchmark: |
| methods: |
| - processArrayOfNestedStringField |
| - processArrayOfStringField |
| - processByteBufferField |
| - processBytesField |
| - processDateTimeField |
| - processIntField |
| - processMapOfIntField |
| - processMapOfNestedIntField |
| - processNestedBytesField |
| - processNestedIntField |
| - processStringBuilderField |
| - processStringField |
| GlobalWindow: |
| methods: |
| - consistentWithEquals |
| - decode |
| - encode |
| - equals |
| - getCoderArguments |
| - hashCode |
| - maxTimestamp |
| - verifyDeterministic |
| properties: |
| - INSTANCE |
| GlobalWindows: |
| methods: |
| - assignWindows |
| - assignsToOneWindow |
| - equals |
| - getDefaultWindowMappingFn |
| - getSideInputWindow |
| - hashCode |
| - isCompatible |
| - toString |
| - verifyCompatibility |
| - windowCoder |
| Group: |
| methods: |
| - aggregate |
| - aggregateField |
| - aggregateFieldBaseValue |
| - aggregateFields |
| - aggregateFieldsById |
| - byFieldAccessDescriptor |
| - byFieldIds |
| - byFieldNames |
| - create |
| - expand |
| - getToKvs |
| - globally |
| - process |
| - witValueField |
| - withKeyField |
| - withValueField |
| GroupByKey: |
| methods: |
| - applicableTo |
| - create |
| - expand |
| - fewKeys |
| - getInputValueCoder |
| - getKeyCoder |
| - getOutputKvCoder |
| - populateDisplayData |
| - updateWindowingStrategy |
| - validate |
| GroupByKeyLoadTest: |
| methods: |
| - main |
| - processElement |
| GroupIntoBatches: |
| methods: |
| - apply |
| - create |
| - createDefault |
| - expand |
| - getBatchSize |
| - getBatchSizeBytes |
| - getBatchingParams |
| - getElementByteSize |
| - getMaxBufferingDuration |
| - getWeigher |
| - identity |
| - ofByteSize |
| - ofSize |
| - onBufferingTimer |
| - onWindowExpiration |
| - onWindowTimer |
| - processElement |
| - toString |
| - withByteSize |
| - withMaxBufferingDuration |
| - withShardedKey |
| - withSize |
| GrowableOffsetRangeTracker: |
| methods: |
| - getProgress |
| - isBounded |
| - trySplit |
| GrpcContextHeaderAccessorProvider: |
| methods: |
| - getHeaderAccessor |
| - getSdkWorkerId |
| - interceptCall |
| - interceptor |
| GrpcFnServer: |
| methods: |
| - allocatePortAndCreateFor |
| - close |
| - create |
| - getApiServiceDescriptor |
| - getServer |
| - getService |
| HBaseCoderProviderRegistrar: |
| methods: |
| - getCoderProviders |
| HBaseIO: |
| methods: |
| - advance |
| - close |
| - createReader |
| - equals |
| - expand |
| - finishBundle |
| - getConfiguration |
| - getCurrent |
| - getCurrentSource |
| - getEstimatedSizeBytes |
| - getFractionConsumed |
| - getKeyRange |
| - getOutputCoder |
| - getScan |
| - getSplitPointsConsumed |
| - getTableId |
| - hashCode |
| - populateDisplayData |
| - processElement |
| - read |
| - readAll |
| - setup |
| - split |
| - splitAtFraction |
| - start |
| - startBundle |
| - tearDown |
| - validate |
| - withConfiguration |
| - withFilter |
| - withKeyRange |
| - withScan |
| - withTableId |
| - write |
| HCatToRow: |
| methods: |
| - expand |
| - fromSpec |
| - processElement |
| HCatalogBeamSchema: |
| methods: |
| - create |
| - getTableSchema |
| - hasDatabase |
| HCatalogIO: |
| methods: |
| - advance |
| - close |
| - createReader |
| - expand |
| - finishBundle |
| - getCurrent |
| - getCurrentSource |
| - getEstimatedSizeBytes |
| - getOutputCoder |
| - initiateWrite |
| - populateDisplayData |
| - processElement |
| - read |
| - split |
| - start |
| - startBundle |
| - tearDown |
| - withBatchSize |
| - withConfigProperties |
| - withDatabase |
| - withFilter |
| - withPartition |
| - withPartitionCols |
| - withPollingInterval |
| - withTable |
| - withTerminationCondition |
| - write |
| HCatalogTable: |
| methods: |
| - buildIOReader |
| - buildIOWriter |
| - config |
| - database |
| - getSchema |
| - isBounded |
| - schema |
| - table |
| HCatalogUtils: {} |
| HDFSSynchronization: |
| methods: |
| - acquireTaskAttemptIdLock |
| - acquireTaskIdLock |
| - releaseJobIdLock |
| - tryAcquireJobLock |
| HL7v2IO: |
| methods: |
| - expand |
| - finishSpecifyingOutput |
| - getAll |
| - getEarliestToLatestRestriction |
| - getFailedInsertsWithErr |
| - getFailedReads |
| - getMessages |
| - getPipeline |
| - ingestMessages |
| - initClient |
| - instantiateHealthcareClient |
| - listMessages |
| - of |
| - processElement |
| - read |
| - readAll |
| - readAllWithFilter |
| - readWithFilter |
| - split |
| - withInitialSplitDuration |
| - writeMessages |
| properties: |
| - DEAD_LETTER |
| - FAILED |
| - OUT |
| - SUCCESS |
| HL7v2Message: |
| methods: |
| - fromModel |
| - getCreateTime |
| - getData |
| - getLabels |
| - getMessageType |
| - getName |
| - getSchematizedData |
| - getSendFacility |
| - getSendTime |
| - setSchematizedData |
| - toModel |
| - toString |
| HL7v2MessageCoder: |
| methods: |
| - decode |
| - encode |
| - of |
| HadoopFileSystemModule: |
| methods: |
| - deserialize |
| - serialize |
| HadoopFileSystemOptionsRegistrar: |
| methods: |
| - getPipelineOptions |
| HadoopFileSystemRegistrar: |
| methods: |
| - fromOptions |
| HadoopFormatIO: |
| methods: |
| - advance |
| - close |
| - createReader |
| - decode |
| - encode |
| - expand |
| - finishBundle |
| - getConfiguration |
| - getCurrent |
| - getCurrentSource |
| - getDefaultCoder |
| - getEstimatedSizeBytes |
| - getFractionConsumed |
| - getKeyCoder |
| - getKeyTranslationFunction |
| - getKeyTypeDescriptor |
| - getOutputCoder |
| - getSkipKeyClone |
| - getSkipValueClone |
| - getSplit |
| - getSplitPointsRemaining |
| - getValueCoder |
| - getValueTranslationFunction |
| - getValueTypeDescriptor |
| - getinputFormatClass |
| - getinputFormatKeyClass |
| - getinputFormatValueClass |
| - populateDisplayData |
| - processElement |
| - read |
| - setup |
| - split |
| - start |
| - startBundle |
| - toBuilder |
| - toString |
| - validate |
| - validateTransform |
| - withConfiguration |
| - withConfigurationTransform |
| - withExternalSynchronization |
| - withKeyTranslation |
| - withPartitioning |
| - withSkipKeyClone |
| - withSkipValueClone |
| - withValueTranslation |
| - withoutPartitioning |
| - write |
| properties: |
| - JOB_ID |
| - NUM_REDUCES |
| - OUTPUT_DIR |
| - OUTPUT_FORMAT_CLASS_ATTR |
| - OUTPUT_KEY_CLASS |
| - OUTPUT_VALUE_CLASS |
| - PARTITIONER_CLASS_ATTR |
| HarnessMonitoringInfosInstructionHandler: |
| methods: |
| - harnessMonitoringInfos |
| HarnessStreamObserverFactories: |
| methods: |
| - fromOptions |
| HealthcareIOError: |
| methods: |
| - getDataResource |
| - getErrorMessage |
| - getObservedTime |
| - getStackTrace |
| - getStatusCode |
| HealthcareIOErrorCoder: |
| methods: |
| - decode |
| - encode |
| - of |
| HealthcareIOErrorToTableRow: |
| methods: |
| - apply |
| properties: |
| - TABLE_FIELD_SCHEMAS |
| - TIMESTAMP_FIELD_NAME |
| HeartbeatRecord: |
| methods: |
| - equals |
| - getRecordTimestamp |
| - getTimestamp |
| - hashCode |
| - toString |
| HeartbeatRecordAction: |
| methods: |
| - run |
| HistogramData: |
| methods: |
| - clear |
| - equals |
| - getAccumulatedBucketSize |
| - getBottomBucketCount |
| - getBucketIndex |
| - getBucketSize |
| - getBucketType |
| - getCount |
| - getNumBuckets |
| - getPercentileString |
| - getRangeFrom |
| - getRangeTo |
| - getStart |
| - getTopBucketCount |
| - getTotalCount |
| - getWidth |
| - hashCode |
| - incBottomBucketCount |
| - incBucketCount |
| - incTopBucketCount |
| - linear |
| - of |
| - p50 |
| - p90 |
| - p99 |
| - record |
| - update |
| HllCount: |
| methods: |
| - expand |
| - forBytes |
| - forIntegers |
| - forLongs |
| - forStrings |
| - getSketchFromByteBuffer |
| - globally |
| - perKey |
| - processElement |
| - withPrecision |
| properties: |
| - DEFAULT_PRECISION |
| - MAXIMUM_PRECISION |
| - MINIMUM_PRECISION |
| HttpClientConfiguration: |
| methods: |
| - build |
| - builder |
| - connectionAcquisitionTimeout |
| - connectionMaxIdleTime |
| - connectionTimeToLive |
| - connectionTimeout |
| - maxConnections |
| - readTimeout |
| - socketTimeout |
| - writeTimeout |
| HttpHealthcareApiClient: |
| methods: |
| - createDicomStore |
| - createFhirStore |
| - createHL7v2Message |
| - createHL7v2Store |
| - deidentifyFhirStore |
| - deleteDicomStore |
| - deleteFhirStore |
| - deleteHL7v2Message |
| - deleteHL7v2Store |
| - executeFhirBundle |
| - exportFhirResourceToBigQuery |
| - exportFhirResourceToGcs |
| - getEarliestHL7v2SendTime |
| - getEnd |
| - getHL7v2Message |
| - getHL7v2Store |
| - getJsonFactory |
| - getLatestHL7v2SendTime |
| - getPatientEverything |
| - getStart |
| - hasNext |
| - importFhirResource |
| - ingestHL7v2Message |
| - initialize |
| - iterator |
| - listAllFhirStores |
| - makeHL7v2ListRequest |
| - makeListRequest |
| - makeSendTimeBoundHL7v2ListRequest |
| - next |
| - ofPatientEverything |
| - ofSearch |
| - pollOperation |
| - readFhirResource |
| - retrieveDicomStudyMetadata |
| - searchFhirResource |
| - uploadToDicomStore |
| IOITMetrics: |
| methods: |
| - publishToInflux |
| IOUtils: |
| methods: |
| - forEach |
| IdGenerators: |
| methods: |
| - decrementingLongs |
| - incrementingLongs |
| IdNameReserve: |
| methods: |
| - decode |
| - encode |
| - equals |
| - hashCode |
| - sizeInBytes |
| - structuralValue |
| - toString |
| - verifyDeterministic |
| properties: |
| - CODER |
| IdentityWindowFn: |
| methods: |
| - assignWindows |
| - assignsToOneWindow |
| - getDefaultWindowMappingFn |
| - isCompatible |
| - verifyCompatibility |
| - windowCoder |
| IllegalMutationException: |
| methods: |
| - getNewValue |
| - getSavedValue |
| Impulse: |
| methods: |
| - create |
| - expand |
| InMemoryMetaStore: |
| methods: |
| - buildBeamSqlTable |
| - createTable |
| - dropTable |
| - getTableType |
| - getTables |
| - registerProvider |
| InMemoryMetaTableProvider: |
| methods: |
| - createTable |
| - dropTable |
| - getTables |
| InProcessServerFactory: |
| methods: |
| - allocateAddressAndCreate |
| - create |
| IncompatibleWindowException: |
| methods: |
| - getMessage |
| InferableFunction: |
| methods: |
| - apply |
| - fromProcessFunctionWithOutputType |
| - getInputTypeDescriptor |
| - getOutputTypeDescriptor |
| - populateDisplayData |
| InfluxDBPublisher: |
| methods: |
| - dataPoint |
| - fields |
| - measurement |
| - publish |
| - publishNexmarkResults |
| - publishWithSettings |
| - tags |
| - timestamp |
| - timestampUnit |
| - toString |
| InfluxDBSettings: |
| methods: |
| - builder |
| - copyWithMeasurement |
| - get |
| - withDatabase |
| - withHost |
| - withMeasurement |
| - withRetentionPolicy |
| properties: |
| - database |
| - host |
| - measurement |
| - retentionPolicy |
| - userName |
| - userPassword |
| InfluxDbIO: |
| methods: |
| - advance |
| - checkClientTrusted |
| - checkServerTrusted |
| - close |
| - create |
| - createReader |
| - expand |
| - finishBundle |
| - getAcceptedIssuers |
| - getConnection |
| - getCurrent |
| - getCurrentSource |
| - getEstimatedSizeBytes |
| - getOutputCoder |
| - populateDisplayData |
| - processElement |
| - read |
| - setDisableCertificateValidation |
| - split |
| - start |
| - startBundle |
| - tearDown |
| - validate |
| - withBatchSize |
| - withConsistencyLevel |
| - withDataSourceConfiguration |
| - withDatabase |
| - withDisableCertificateValidation |
| - withFromDateTime |
| - withMetric |
| - withQuery |
| - withRetentionPolicy |
| - withToDateTime |
| - write |
| InitialPartition: |
| methods: |
| - isInitialPartition |
| properties: |
| - PARENT_TOKENS |
| - PARTITION_TOKEN |
| InitializeDoFn: |
| methods: |
| - processElement |
| InsertRetryPolicy: |
| methods: |
| - alwaysRetry |
| - getInsertErrors |
| - neverRetry |
| - retryTransientErrors |
| - shouldRetry |
| InstanceBuilder: |
| methods: |
| - build |
| - fromClass |
| - fromClassName |
| - fromFactoryMethod |
| - ofType |
| - withArg |
| InstanceUtils: |
| methods: |
| - create |
| - forName |
| InstantCoder: |
| methods: |
| - consistentWithEquals |
| - decode |
| - encode |
| - getEncodedTypeDescriptor |
| - isRegisterByteSizeObserverCheap |
| - of |
| - verifyDeterministic |
| InstantDeserializer: |
| methods: |
| - close |
| - configure |
| - deserialize |
| InstantSerializer: |
| methods: |
| - close |
| - configure |
| - serialize |
| IntervalWindow: |
| methods: |
| - compareTo |
| - consistentWithEquals |
| - contains |
| - decode |
| - encode |
| - end |
| - equals |
| - getCoder |
| - getCoderArguments |
| - hashCode |
| - intersects |
| - isDisjoint |
| - isRegisterByteSizeObserverCheap |
| - maxTimestamp |
| - of |
| - registerByteSizeObserver |
| - span |
| - start |
| - toString |
| - verifyDeterministic |
| InvalidConfigurationException: {} |
| InvalidLocationException: {} |
| InvalidSchemaException: {} |
| InvalidTableException: {} |
| IsInf: |
| methods: |
| - isInf |
| IsNan: |
| methods: |
| - isNan |
| IterableCoder: |
| methods: |
| - getEncodedTypeDescriptor |
| - of |
| - structuralValue |
| IterableLikeCoder: |
| methods: |
| - decode |
| - encode |
| - getCoderArguments |
| - getElemCoder |
| - isRegisterByteSizeObserverCheap |
| - registerByteSizeObserver |
| - update |
| - verifyDeterministic |
| IterableSideInput: |
| methods: |
| - get |
| JAXBCoder: |
| methods: |
| - close |
| - decode |
| - encode |
| - equals |
| - getEncodedTypeDescriptor |
| - getJAXBClass |
| - hashCode |
| - of |
| - write |
| JavaBeanSchema: |
| methods: |
| - create |
| - equals |
| - fieldValueGetters |
| - fieldValueTypeInformations |
| - get |
| - hashCode |
| - schemaFor |
| - schemaTypeCreator |
| properties: |
| - INSTANCE |
| JavaBeanUtils: |
| methods: |
| - appender |
| - createConstructorCreator |
| - createGetter |
| - createSetter |
| - createStaticCreator |
| - getConstructorCreator |
| - getFieldTypes |
| - getGetters |
| - getSetters |
| - getStaticCreator |
| - prepare |
| - schemaFromJavaBeanClass |
| - validateJavaBean |
| properties: |
| - CACHED_CREATORS |
| JavaFieldSchema: |
| methods: |
| - fieldValueGetters |
| - fieldValueTypeInformations |
| - get |
| - schemaFor |
| - schemaTypeCreator |
| properties: |
| - INSTANCE |
| JavaUdfLoader: |
| methods: |
| - createClassLoader |
| - loadAggregateFunction |
| - loadScalarFunction |
| - run |
| JdbcConnection: |
| methods: |
| - getCurrentSchemaPlus |
| - getPipelineOptions |
| - setPipelineOptions |
| - setPipelineOptionsMap |
| JdbcDriver: |
| methods: |
| - connect |
| properties: |
| - CONNECT_STRING_PREFIX |
| - INSTANCE |
| - OBJECT_MAPPER |
| JdbcIO: |
| methods: |
| - apply |
| - create |
| - expand |
| - finish |
| - finishBundle |
| - of |
| - populateDisplayData |
| - process |
| - processElement |
| - read |
| - readAll |
| - readRows |
| - readWithPartitions |
| - setParameters |
| - setup |
| - tearDown |
| - withAutoSharding |
| - withBatchSize |
| - withCoder |
| - withConnectionInitSqls |
| - withConnectionProperties |
| - withDataSourceConfiguration |
| - withDataSourceProviderFn |
| - withDriverClassLoader |
| - withFetchSize |
| - withLowerBound |
| - withNumPartitions |
| - withOutputParallelization |
| - withParameterSetter |
| - withPartitionColumn |
| - withPassword |
| - withPreparedStatementSetter |
| - withQuery |
| - withResults |
| - withRetryConfiguration |
| - withRetryStrategy |
| - withRowMapper |
| - withRowOutput |
| - withStatement |
| - withStatementPreparator |
| - withTable |
| - withUpperBound |
| - withUsername |
| - withWriteResults |
| - write |
| - writeVoid |
| JdbcReadSchemaTransformProvider: |
| methods: |
| - build |
| - buildTransform |
| - builder |
| - expand |
| - getConnectionInitSql |
| - getConnectionProperties |
| - getDriverClassName |
| - getFetchSize |
| - getJdbcUrl |
| - getLocation |
| - getOutputParallelization |
| - getPassword |
| - getReadQuery |
| - getUsername |
| - identifier |
| - inputCollectionNames |
| - outputCollectionNames |
| - setConnectionInitSql |
| - setConnectionProperties |
| - setDriverClassName |
| - setFetchSize |
| - setJdbcUrl |
| - setLocation |
| - setOutputParallelization |
| - setPassword |
| - setReadQuery |
| - setUsername |
| - validate |
| JdbcSchemaIOProvider: |
| methods: |
| - buildReader |
| - buildWriter |
| - configurationSchema |
| - expand |
| - from |
| - identifier |
| - isBounded |
| - requiresDataSchema |
| - schema |
| JdbcWriteResult: |
| methods: |
| - create |
| JdbcWriteSchemaTransformProvider: |
| methods: |
| - build |
| - buildTransform |
| - builder |
| - expand |
| - getAutosharding |
| - getConnectionInitSql |
| - getConnectionProperties |
| - getDriverClassName |
| - getJdbcUrl |
| - getLocation |
| - getPassword |
| - getUsername |
| - getWriteStatement |
| - identifier |
| - inputCollectionNames |
| - outputCollectionNames |
| - setAutosharding |
| - setConnectionInitSql |
| - setConnectionProperties |
| - setDriverClassName |
| - setJdbcUrl |
| - setLocation |
| - setPassword |
| - setUsername |
| - setWriteStatement |
| - validate |
| JmsIO: |
| methods: |
| - advance |
| - close |
| - createReader |
| - expand |
| - getCheckpointMark |
| - getCheckpointMarkCoder |
| - getCurrent |
| - getCurrentSource |
| - getCurrentTimestamp |
| - getOutputCoder |
| - getTotalBacklogBytes |
| - getWatermark |
| - mapMessage |
| - populateDisplayData |
| - processElement |
| - read |
| - readMessage |
| - setup |
| - split |
| - start |
| - teardown |
| - withAutoScaler |
| - withCloseTimeout |
| - withCoder |
| - withConnectionFactory |
| - withMaxNumRecords |
| - withMaxReadTime |
| - withMessageMapper |
| - withPassword |
| - withQueue |
| - withTopic |
| - withTopicNameMapper |
| - withUsername |
| - withValueMapper |
| - write |
| JmsIOException: {} |
| JmsRecord: |
| methods: |
| - equals |
| - getJmsCorrelationID |
| - getJmsDeliveryMode |
| - getJmsDestination |
| - getJmsExpiration |
| - getJmsMessageID |
| - getJmsPriority |
| - getJmsRedelivered |
| - getJmsReplyTo |
| - getJmsTimestamp |
| - getJmsType |
| - getPayload |
| - getProperties |
| - hashCode |
| Join: |
| methods: |
| - accumulationMode |
| - by |
| - expand |
| - fullOuterJoin |
| - getJoiner |
| - getLeftKeyExtractor |
| - getRightKeyExtractor |
| - getType |
| - innerBroadcastJoin |
| - innerJoin |
| - left |
| - leftOuterBroadcastJoin |
| - leftOuterJoin |
| - named |
| - of |
| - on |
| - output |
| - outputValues |
| - processElement |
| - right |
| - rightOuterJoin |
| - triggeredBy |
| - using |
| - windowBy |
| - with |
| - withAllowedLateness |
| - withOnTimeBehavior |
| - withTimestampCombiner |
| properties: |
| - LHS_TAG |
| - RHS_TAG |
| JoinRelOptRuleCall: |
| methods: |
| - builder |
| - getChildRels |
| - getMetadataQuery |
| - getOperand0 |
| - getParents |
| - getPlanner |
| - getRelList |
| - getRule |
| - rel |
| - transformTo |
| JoinTranslator: |
| methods: |
| - getFnName |
| - processElement |
| JsonArrayCoder: |
| methods: |
| - decode |
| - encode |
| - of |
| JsonMatcher: |
| methods: |
| - describeTo |
| - jsonBytesLike |
| - jsonStringLike |
| JsonPayloadSerializerProvider: |
| methods: |
| - getSerializer |
| - identifier |
| JsonToRow: |
| methods: |
| - build |
| - create |
| - expand |
| - finishSpecifyingOutput |
| - getFailedToParseLines |
| - getJsonToRowWithErrFn |
| - getPipeline |
| - getResults |
| - processElement |
| - resultBuilder |
| - setErrorField |
| - setJsonToRowWithErrFn |
| - setLineField |
| - toBuilder |
| - withExceptionReporting |
| - withExtendedErrorInfo |
| - withNullBehavior |
| - withSchema |
| - withSchemaAndNullBehavior |
| properties: |
| - ERROR_ROW_SCHEMA |
| - ERROR_ROW_WITH_ERR_MSG_SCHEMA |
| JsonUtils: |
| methods: |
| - apply |
| - beamSchemaFromJsonSchema |
| - getJsonBytesToRowFunction |
| - getJsonStringToRowFunction |
| - getRowToJsonBytesFunction |
| - getRowToJsonStringsFunction |
| JvmInitializers: |
| methods: |
| - runBeforeProcessing |
| - runOnStartup |
| KV: |
| methods: |
| - compare |
| - equals |
| - getKey |
| - getValue |
| - hashCode |
| - of |
| - toString |
| KafkaCheckpointMark: |
| methods: |
| - finalizeCheckpoint |
| - getNextOffset |
| - getPartition |
| - getPartitions |
| - getTopic |
| - getWatermarkMillis |
| - toString |
| KafkaCommitOffset: |
| methods: |
| - expand |
| - processElement |
| KafkaConnectUtils: |
| methods: |
| - beamRowFromSourceRecordFn |
| - beamSchemaFromKafkaConnectSchema |
| - beamSchemaTypeFromKafkaType |
| - mapSourceRecord |
| KafkaIO: |
| methods: |
| - apply |
| - buildExternal |
| - commitOffsets |
| - commitOffsetsInFinalize |
| - decode |
| - encode |
| - expand |
| - externalWithMetadata |
| - getReplacementTransform |
| - getTimestamp |
| - knownBuilders |
| - mapOutputs |
| - populateDisplayData |
| - processElement |
| - read |
| - readBytes |
| - readSourceDescriptors |
| - setCommitOffsetInFinalize |
| - setConsumerConfig |
| - setKeyDeserializer |
| - setKeySerializer |
| - setMaxNumRecords |
| - setMaxReadTime |
| - setProducerConfig |
| - setStartReadTime |
| - setStopReadTime |
| - setTimestampPolicy |
| - setTopic |
| - setTopics |
| - setValueDeserializer |
| - setValueSerializer |
| - toExternalKafkaRecord |
| - updateConsumerProperties |
| - updateProducerProperties |
| - useCreateTime |
| - useLogAppendTime |
| - useProcessingTime |
| - validate |
| - values |
| - withBootstrapServers |
| - withCheckStopReadingFn |
| - withConsumerConfigOverrides |
| - withConsumerConfigUpdates |
| - withConsumerFactoryFn |
| - withCreatWatermarkEstimatorFn |
| - withCreateTime |
| - withDynamicRead |
| - withEOS |
| - withExtractOutputTimestampFn |
| - withInputTimestamp |
| - withKeyDeserializer |
| - withKeyDeserializerAndCoder |
| - withKeyDeserializerProvider |
| - withKeySerializer |
| - withLogAppendTime |
| - withManualWatermarkEstimator |
| - withMaxNumRecords |
| - withMaxReadTime |
| - withMonotonicallyIncreasingWatermarkEstimator |
| - withOffsetConsumerConfigOverrides |
| - withProcessingTime |
| - withProducerConfigUpdates |
| - withProducerFactoryFn |
| - withPublishTimestampFunction |
| - withReadCommitted |
| - withStartReadTime |
| - withStopReadTime |
| - withTimestampFn |
| - withTimestampFn2 |
| - withTimestampPolicyFactory |
| - withTopic |
| - withTopicPartitions |
| - withTopics |
| - withValueDeserializer |
| - withValueDeserializerAndCoder |
| - withValueDeserializerProvider |
| - withValueSerializer |
| - withWallTimeWatermarkEstimator |
| - withWatermarkFn |
| - withWatermarkFn2 |
| - withoutMetadata |
| - write |
| - writeRecords |
| properties: |
| - KAFKA_READ_OVERRIDE |
| - URN |
| - URN_WITHOUT_METADATA |
| - URN_WITH_METADATA |
| KafkaReadSchemaTransformConfiguration: |
| methods: |
| - build |
| - builder |
| - getAutoOffsetResetConfig |
| - getBootstrapServers |
| - getConfluentSchemaRegistrySubject |
| - getConfluentSchemaRegistryUrl |
| - getConsumerConfigUpdates |
| - getDataFormat |
| - getSchema |
| - getTopic |
| - setAutoOffsetResetConfig |
| - setBootstrapServers |
| - setConfluentSchemaRegistrySubject |
| - setConfluentSchemaRegistryUrl |
| - setConsumerConfigUpdates |
| - setDataFormat |
| - setSchema |
| - setTopic |
| - validate |
| properties: |
| - VALID_DATA_FORMATS |
| - VALID_START_OFFSET_VALUES |
| KafkaReadSchemaTransformProvider: |
| methods: |
| - buildTransform |
| - expand |
| - identifier |
| - inputCollectionNames |
| - outputCollectionNames |
| KafkaRecord: |
| methods: |
| - equals |
| - getHeaders |
| - getKV |
| - getOffset |
| - getPartition |
| - getTimestamp |
| - getTimestampType |
| - getTopic |
| - hashCode |
| KafkaRecordCoder: |
| methods: |
| - consistentWithEquals |
| - decode |
| - encode |
| - getCoderArguments |
| - isRegisterByteSizeObserverCheap |
| - of |
| - structuralValue |
| - verifyDeterministic |
| KafkaSourceConsumerFn: |
| methods: |
| - checkDone |
| - configs |
| - currentRestriction |
| - exists |
| - getHashCode |
| - getInitialRestriction |
| - getRestrictionCoder |
| - isBounded |
| - newTracker |
| - offset |
| - offsetStorageReader |
| - offsets |
| - process |
| - start |
| - storageExists |
| - tryClaim |
| - trySplit |
| properties: |
| - BEAM_INSTANCE_PROPERTY |
| - fetchedRecords |
| - history |
| - maxRecords |
| - milisToRun |
| - offset |
| KafkaSourceDescriptor: |
| methods: |
| - getTopicPartition |
| - of |
| KafkaTableProvider: |
| methods: |
| - buildBeamSqlTable |
| - getTableType |
| KafkaWriteSchemaTransformProvider: |
| methods: |
| - build |
| - buildTransform |
| - builder |
| - expand |
| - getBootstrapServers |
| - getFormat |
| - getProducerConfigUpdates |
| - getTopic |
| - identifier |
| - inputCollectionNames |
| - outputCollectionNames |
| - setBootstrapServers |
| - setFormat |
| - setProducerConfigUpdates |
| - setTopic |
| properties: |
| - SUPPORTED_FORMATS |
| KeyPairUtils: |
| methods: |
| - preparePrivateKey |
| - readPrivateKeyFile |
| KeyedPCollectionTuple: |
| methods: |
| - and |
| - apply |
| - empty |
| - expand |
| - getCoGbkResultSchema |
| - getCollection |
| - getKeyCoder |
| - getKeyedCollections |
| - getPipeline |
| - getTupleTag |
| - isEmpty |
| - of |
| Keys: |
| methods: |
| - apply |
| - create |
| - expand |
| KinesisClientThrottledException: {} |
| KinesisIO: |
| methods: |
| - addPutRecordsRequest |
| - build |
| - builder |
| - close |
| - expand |
| - finishBundle |
| - finishSpecifyingOutput |
| - getPipeline |
| - maxBufferedTime |
| - maxBytes |
| - processElement |
| - read |
| - readData |
| - refreshPeriodically |
| - setup |
| - shardAwareHashKey |
| - shardRefreshInterval |
| - startBundle |
| - teardown |
| - withAWSClientsProvider |
| - withArrivalTimeWatermarkPolicy |
| - withBatchMaxBytes |
| - withBatchMaxRecords |
| - withClientConfiguration |
| - withConcurrentRequests |
| - withCustomRateLimitPolicy |
| - withCustomWatermarkPolicy |
| - withDynamicDelayRateLimitPolicy |
| - withFixedDelayRateLimitPolicy |
| - withInitialPositionInStream |
| - withInitialTimestampInStream |
| - withMaxCapacityPerShard |
| - withMaxNumRecords |
| - withMaxReadTime |
| - withPartitionKey |
| - withPartitioner |
| - withProcessingTimeWatermarkPolicy |
| - withProducerProperties |
| - withRecordAggregation |
| - withRecordAggregationDisabled |
| - withRequestRecordsLimit |
| - withSerializer |
| - withStreamName |
| - withUpToDateThreshold |
| - write |
| KinesisRecord: |
| methods: |
| - equals |
| - getApproximateArrivalTimestamp |
| - getData |
| - getDataAsBytes |
| - getExtendedSequenceNumber |
| - getPartitionKey |
| - getReadTime |
| - getSequenceNumber |
| - getShardId |
| - getStreamName |
| - getSubSequenceNumber |
| - getUniqueId |
| - hashCode |
| - toString |
| KinesisTransformRegistrar: |
| methods: |
| - buildExternal |
| - knownBuilderInstances |
| - setAwsAccessKey |
| - setAwsSecretKey |
| - setInitialPositionInStream |
| - setInitialTimestampInStream |
| - setMaxCapacityPerShard |
| - setMaxNumRecords |
| - setMaxReadTime |
| - setPartitionKey |
| - setProducerProperties |
| - setRateLimit |
| - setRegion |
| - setRequestRecordsLimit |
| - setServiceEndpoint |
| - setStreamName |
| - setUpToDateThreshold |
| - setVerifyCertificate |
| - setWatermarkIdleDurationThreshold |
| - setWatermarkPolicy |
| properties: |
| - READ_DATA_URN |
| - WRITE_URN |
| KryoCoder: |
| methods: |
| - decode |
| - encode |
| - equals |
| - hashCode |
| - of |
| - verifyDeterministic |
| - withRegistrar |
| KryoCoderProvider: |
| methods: |
| - coderFor |
| - of |
| - registerTo |
| - withRegistrar |
| KuduIO: |
| methods: |
| - createReader |
| - expand |
| - finishBundle |
| - getEstimatedSizeBytes |
| - getOutputCoder |
| - populateDisplayData |
| - processElement |
| - read |
| - setup |
| - split |
| - startBundle |
| - teardown |
| - validate |
| - withBatchSize |
| - withCoder |
| - withFaultTolerent |
| - withFormatFn |
| - withMasterAddresses |
| - withParseFn |
| - withPredicates |
| - withProjectedColumns |
| - withTable |
| - write |
| KvCoder: |
| methods: |
| - consistentWithEquals |
| - decode |
| - encode |
| - getCoderArguments |
| - getEncodedTypeDescriptor |
| - getKeyCoder |
| - getValueCoder |
| - isRegisterByteSizeObserverCheap |
| - of |
| - registerByteSizeObserver |
| - structuralValue |
| - verifyDeterministic |
| KvSwap: |
| methods: |
| - apply |
| - create |
| - expand |
| LatencyRecordingHttpRequestInitializer: |
| methods: |
| - initialize |
| - intercept |
| - interceptResponse |
| properties: |
| - HISTOGRAM_BUCKET_TYPE |
| Latest: |
| methods: |
| - addInput |
| - combineFn |
| - createAccumulator |
| - expand |
| - extractOutput |
| - getAccumulatorCoder |
| - getDefaultOutputCoder |
| - globally |
| - mergeAccumulators |
| - perKey |
| LazyAggregateCombineFn: |
| methods: |
| - addInput |
| - createAccumulator |
| - extractOutput |
| - getAccumTVariable |
| - getAccumulatorCoder |
| - getUdafImpl |
| - iterator |
| - mergeAccumulators |
| - toString |
| LeftJoin: |
| methods: |
| - by |
| - named |
| - of |
| - using |
| LengthPrefixCoder: |
| methods: |
| - consistentWithEquals |
| - decode |
| - encode |
| - getCoderArguments |
| - getValueCoder |
| - isRegisterByteSizeObserverCheap |
| - of |
| - verifyDeterministic |
| ListCoder: |
| methods: |
| - consistentWithEquals |
| - getEncodedTypeDescriptor |
| - of |
| - structuralValue |
| - verifyDeterministic |
| LoadTestResult: |
| methods: |
| - getRuntime |
| - getTotalBytesCount |
| - toMap |
| LocalFileSystemRegistrar: |
| methods: |
| - fromOptions |
| LocalResources: |
| methods: |
| - fromFile |
| - fromPath |
| - fromString |
| LogicalCalcMergeRule: |
| methods: |
| - onMatch |
| properties: |
| - INSTANCE |
| LogicalEndpoint: |
| methods: |
| - data |
| - getInstructionId |
| - getTimerFamilyId |
| - getTransformId |
| - isTimer |
| - timer |
| LongGenerator: |
| methods: |
| - nextLong |
| LzoCompression: |
| methods: |
| - createLzoInputStream |
| - createLzoOutputStream |
| - createLzopInputStream |
| - createLzopOutputStream |
| Main: |
| methods: |
| - call |
| - main |
| ManagedChannelFactory: |
| methods: |
| - createDefault |
| - createEpoll |
| - createInProcess |
| - forDescriptor |
| - withDirectExecutor |
| - withInterceptors |
| ManagedFactoryImpl: |
| methods: |
| - close |
| - create |
| MapCoder: |
| methods: |
| - consistentWithEquals |
| - decode |
| - encode |
| - getCoderArguments |
| - getEncodedTypeDescriptor |
| - getKeyCoder |
| - getValueCoder |
| - of |
| - registerByteSizeObserver |
| - structuralValue |
| - verifyDeterministic |
| MapElements: |
| methods: |
| - exceptionsInto |
| - exceptionsVia |
| - expand |
| - getInputTypeDescriptor |
| - getMapper |
| - getOutputTypeDescriptor |
| - getTypeDescriptor |
| - into |
| - named |
| - of |
| - output |
| - populateDisplayData |
| - processElement |
| - using |
| - via |
| MapFnRunners: |
| methods: |
| - create |
| - createRunnerForPTransform |
| - forValueMapFnFactory |
| - forWindowedValueMapFnFactory |
| MapKeys: |
| methods: |
| - exceptionsInto |
| - exceptionsVia |
| - expand |
| - into |
| - via |
| MapValues: |
| methods: |
| - exceptionsInto |
| - exceptionsVia |
| - expand |
| - into |
| - via |
| MapperFactory: |
| methods: |
| - changeStreamRecordMapper |
| - partitionMetadataMapper |
| MappingUtils: {} |
| MatchResult: |
| methods: |
| - build |
| - builder |
| - checksum |
| - create |
| - isReadSeekEfficient |
| - lastModifiedMillis |
| - metadata |
| - resourceId |
| - setChecksum |
| - setIsReadSeekEfficient |
| - setLastModifiedMillis |
| - setResourceId |
| - setSizeBytes |
| - sizeBytes |
| - status |
| - unknown |
| Materializations: |
| methods: |
| - getUrn |
| - iterable |
| - multimap |
| properties: |
| - ITERABLE_MATERIALIZATION_URN |
| - MULTIMAP_MATERIALIZATION_URN |
| Max: |
| methods: |
| - apply |
| - doublesGlobally |
| - doublesPerKey |
| - globally |
| - identity |
| - integersGlobally |
| - integersPerKey |
| - longsGlobally |
| - longsPerKey |
| - naturalOrder |
| - of |
| - ofDoubles |
| - ofIntegers |
| - ofLongs |
| - perKey |
| - populateDisplayData |
| Mean: |
| methods: |
| - addInput |
| - createAccumulator |
| - decode |
| - encode |
| - equals |
| - extractOutput |
| - getAccumulatorCoder |
| - globally |
| - hashCode |
| - mergeAccumulator |
| - of |
| - perKey |
| - toString |
| - verifyDeterministic |
| MemoryMonitor: |
| methods: |
| - describeMemory |
| - dumpHeap |
| - fromOptions |
| - isThrashing |
| - run |
| - stop |
| - totalGCTimeMilliseconds |
| - tryToDumpHeap |
| - waitForResources |
| - waitForThrashingState |
| properties: |
| - DEFAULT_SLEEP_TIME_MILLIS |
| MergeOverlappingIntervalWindows: |
| methods: |
| - add |
| - apply |
| - intersects |
| - mergeWindows |
| - toString |
| MetadataCoder: |
| methods: |
| - consistentWithEquals |
| - decode |
| - encode |
| - of |
| MetadataCoderV2: |
| methods: |
| - consistentWithEquals |
| - decode |
| - encode |
| - of |
| MetricFiltering: |
| methods: |
| - matches |
| - matchesScope |
| - subPathMatches |
| MetricKey: |
| methods: |
| - create |
| - metricName |
| - stepName |
| - toString |
| MetricName: |
| methods: |
| - getName |
| - getNamespace |
| - named |
| - toString |
| MetricNameFilter: |
| methods: |
| - getName |
| - getNamespace |
| - inNamespace |
| - named |
| MetricQueryResults: |
| methods: |
| - create |
| - getCounters |
| - getDistributions |
| - getGauges |
| - toString |
| MetricResult: |
| methods: |
| - addAttempted |
| - addCommitted |
| - attempted |
| - create |
| - getAttempted |
| - getCommitted |
| - getCommittedOrNull |
| - getKey |
| - getName |
| - hasCommitted |
| - transform |
| MetricResults: |
| methods: |
| - allMetrics |
| - queryMetrics |
| - toString |
| Metrics: |
| methods: |
| - bundleProcessingThreadCounter |
| - bundleProcessingThreadDistribution |
| - counter |
| - dec |
| - distribution |
| - gauge |
| - getName |
| - inc |
| - reset |
| - set |
| - update |
| - updateFinalMonitoringData |
| - updateIntermediateMonitoringData |
| MetricsBenchmark: |
| methods: |
| - check |
| - testBundleProcessingThreadCounterMutation |
| - testBundleProcessingThreadCounterReset |
| - testCounterCellMutation |
| - testCounterCellReset |
| properties: |
| - bundleCounter |
| - counterCell |
| MetricsEnvironment: |
| methods: |
| - activate |
| - close |
| - getCurrentContainer |
| - getMetricsEnvironmentStateForCurrentThread |
| - getProcessWideContainer |
| - isMetricsSupported |
| - scopedMetricsContainer |
| - setCurrentContainer |
| - setMetricsSupported |
| - setProcessWideContainer |
| MetricsFilter: |
| methods: |
| - addNameFilter |
| - addStep |
| - build |
| - builder |
| - names |
| - steps |
| MetricsReader: |
| methods: |
| - getCounterMetric |
| - getEndTimeMetric |
| - getStartTimeMetric |
| - ofResults |
| - readAll |
| - withNamespace |
| MicrosInstant: |
| methods: |
| - getArgumentType |
| - getBaseType |
| - getIdentifier |
| - toBaseType |
| - toInputType |
| properties: |
| - IDENTIFIER |
| MimeTypes: |
| properties: |
| - BINARY |
| - TEXT |
| Min: |
| methods: |
| - apply |
| - doublesGlobally |
| - doublesPerKey |
| - globally |
| - identity |
| - integersGlobally |
| - integersPerKey |
| - longsGlobally |
| - longsPerKey |
| - naturalOrder |
| - of |
| - ofDoubles |
| - ofIntegers |
| - ofLongs |
| - perKey |
| - populateDisplayData |
| Mod: |
| methods: |
| - equals |
| - getKeysJson |
| - getNewValuesJson |
| - getOldValuesJson |
| - hashCode |
| - toString |
| MongoDbGridFSIO: |
| methods: |
| - advance |
| - close |
| - createReader |
| - expand |
| - finishBundle |
| - getAllowedTimestampSkew |
| - getCurrent |
| - getCurrentSource |
| - getCurrentTimestamp |
| - getEstimatedSizeBytes |
| - getOutputCoder |
| - output |
| - populateDisplayData |
| - processElement |
| - read |
| - setup |
| - split |
| - start |
| - startBundle |
| - teardown |
| - validate |
| - withBucket |
| - withChunkSize |
| - withCoder |
| - withDatabase |
| - withFilename |
| - withFilter |
| - withParser |
| - withSkew |
| - withUri |
| - write |
| MongoDbIO: |
| methods: |
| - advance |
| - close |
| - closeMongoClient |
| - createMongoClient |
| - createReader |
| - expand |
| - finishBundle |
| - getCurrent |
| - getCurrentSource |
| - getDocumentCount |
| - getEstimatedSizeBytes |
| - getOutputCoder |
| - populateDisplayData |
| - processElement |
| - read |
| - split |
| - start |
| - startBundle |
| - withBatchSize |
| - withBucketAuto |
| - withCollection |
| - withDatabase |
| - withIgnoreSSLCertificate |
| - withMaxConnectionIdleTime |
| - withNumSplits |
| - withOrdered |
| - withQueryFn |
| - withSSLEnabled |
| - withSSLInvalidHostNameAllowed |
| - withUpdateConfiguration |
| - withUri |
| - write |
| MongoDbTable: |
| methods: |
| - apply |
| - buildIOReader |
| - buildIOWriter |
| - constructFilter |
| - convert |
| - create |
| - expand |
| - getNotSupported |
| - getSupported |
| - getTableStatistics |
| - isBounded |
| - numSupported |
| - processElement |
| - supportsProjects |
| - toString |
| - withSchema |
| MongoDbTableProvider: |
| methods: |
| - buildBeamSqlTable |
| - getTableType |
| Monitor: |
| methods: |
| - getTransform |
| - processElement |
| properties: |
| - name |
| - prefix |
| MoreFutures: |
| methods: |
| - allAsList |
| - allAsListWithExceptions |
| - exception |
| - get |
| - getException |
| - getResult |
| - isCancelled |
| - isDone |
| - isException |
| - result |
| - runAsync |
| - supplyAsync |
| MovingFunction: |
| methods: |
| - add |
| - get |
| - isSignificant |
| MqttIO: |
| methods: |
| - add |
| - advance |
| - close |
| - closeMqttClient |
| - create |
| - createMqttClient |
| - createReader |
| - equals |
| - expand |
| - finalizeCheckpoint |
| - getCheckpointMark |
| - getCheckpointMarkCoder |
| - getCurrent |
| - getCurrentSource |
| - getCurrentTimestamp |
| - getOutputCoder |
| - getWatermark |
| - hashCode |
| - populateDisplayData |
| - processElement |
| - read |
| - split |
| - start |
| - withClientId |
| - withConnectionConfiguration |
| - withMaxNumRecords |
| - withMaxReadTime |
| - withPassword |
| - withRetained |
| - withServerUri |
| - withTopic |
| - withUsername |
| - write |
| MultimapSideInput: |
| methods: |
| - get |
| MultimapUserState: |
| methods: |
| - asyncClose |
| - clear |
| - createIterator |
| - get |
| - hasNext |
| - isReady |
| - keys |
| - next |
| - prefetch |
| - put |
| - remove |
| MutationDetectors: |
| methods: |
| - close |
| - forValueWithCoder |
| - noopMutationDetector |
| - verifyUnmodified |
| MutationGroup: |
| methods: |
| - attached |
| - create |
| - equals |
| - hashCode |
| - iterator |
| - primary |
| - size |
| - toString |
| NFA: |
| methods: |
| - addPrevEvent |
| - assignIndex |
| - atFinal |
| - canDecrement |
| - canTrim |
| - compile |
| - copy |
| - decrement |
| - equals |
| - getCurState |
| - getCurrentEvent |
| - getNewProceedPointer |
| - getNewTakePointer |
| - getNextState |
| - getPatternVar |
| - getPointer |
| - getPrevPointer |
| - getProceedCondition |
| - getQuantifier |
| - getRow |
| - getTakeCondition |
| - hasProceed |
| - hasTake |
| - hashCode |
| - isKleenePlus |
| - isKleenePlusSecondary |
| - isNull |
| - isProceedPointer |
| - proceed |
| - proceedIgnore |
| - processNewRow |
| - reset |
| - setNextState |
| - take |
| - toCEPLiteral |
| - toString |
| - trim |
| properties: |
| - isFinal |
| - isStart |
| NameCityStateId: |
| methods: |
| - decode |
| - encode |
| - equals |
| - hashCode |
| - sizeInBytes |
| - structuralValue |
| - toString |
| - verifyDeterministic |
| properties: |
| - CODER |
| - city |
| - id |
| - name |
| - state |
| NameGenerator: |
| methods: |
| - generatePartitionMetadataTableName |
| NameUtils: |
| methods: |
| - approximatePTransformName |
| - approximateSimpleName |
| NamedTestResult: |
| methods: |
| - create |
| - fields |
| - getMetric |
| - getSchema |
| - getValue |
| - tags |
| - toInfluxDBDataPoint |
| - toMap |
| NanosDuration: |
| methods: |
| - toBaseType |
| - toInputType |
| properties: |
| - IDENTIFIER |
| NanosInstant: |
| methods: |
| - toBaseType |
| - toInputType |
| properties: |
| - IDENTIFIER |
| Neo4jIO: |
| methods: |
| - apply |
| - create |
| - expand |
| - finishBundle |
| - of |
| - populateDisplayData |
| - processElement |
| - readAll |
| - setup |
| - startBundle |
| - tearDown |
| - withBatchSize |
| - withCoder |
| - withConfig |
| - withCypher |
| - withCypherLogging |
| - withDefaultConfig |
| - withDriverConfiguration |
| - withParametersFunction |
| - withPassword |
| - withReadTransaction |
| - withRowMapper |
| - withSessionConfig |
| - withTransactionConfig |
| - withUnwindMapName |
| - withUrl |
| - withUrls |
| - withUsername |
| - withWriteTransaction |
| - writeUnwind |
| properties: |
| - closed |
| - driver |
| - session |
| Never: |
| methods: |
| - ever |
| - getWatermarkThatGuaranteesFiring |
| NexmarkConfiguration: |
| methods: |
| - copy |
| - equals |
| - fromString |
| - hashCode |
| - overrideFromOptions |
| - toShortString |
| - toString |
| properties: |
| - DEFAULT |
| - auctionSkip |
| - avgAuctionByteSize |
| - avgBidByteSize |
| - avgPersonByteSize |
| - coderStrategy |
| - cpuDelayMs |
| - debug |
| - diskBusyBytes |
| - exportSummaryToBigQuery |
| - fanout |
| - firstEventRate |
| - generateEventFilePathPrefix |
| - hotAuctionRatio |
| - hotBiddersRatio |
| - hotSellersRatio |
| - isRateLimited |
| - maxAuctionsWaitingTime |
| - maxLogEvents |
| - nextEventRate |
| - numActivePeople |
| - numEventGenerators |
| - numEvents |
| - numInFlightAuctions |
| - numKeyBuckets |
| - occasionalDelaySec |
| - outOfOrderGroupSize |
| - pardoCPUFactor |
| - preloadSeconds |
| - probDelayedEvent |
| - pubSubMode |
| - pubsubMessageSerializationMethod |
| - query |
| - ratePeriodSec |
| - rateShape |
| - rateUnit |
| - sessionGap |
| - sideInputNumShards |
| - sideInputRowCount |
| - sideInputType |
| - sideInputUrl |
| - sinkType |
| - sourceType |
| - streamTimeout |
| - usePubsubPublishTime |
| - useWallclockEventTime |
| - watermarkHoldbackSec |
| - windowPeriodSec |
| - windowSizeSec |
| NexmarkLauncher: |
| methods: |
| - processElement |
| - run |
| NexmarkPerf: |
| methods: |
| - anyActivity |
| - fromString |
| - toMap |
| - toString |
| properties: |
| - errors |
| - eventBytesPerSec |
| - eventsPerSec |
| - jobId |
| - numEvents |
| - numResults |
| - processingDelaySec |
| - resultBytesPerSec |
| - resultsPerSec |
| - runtimeSec |
| - shutdownDelaySec |
| - snapshots |
| - startupDelaySec |
| NexmarkQuery: |
| methods: |
| - expand |
| - getTransform |
| properties: |
| - eventMonitor |
| - resultMonitor |
| NexmarkQueryModel: |
| methods: |
| - apply |
| - assertionFor |
| - simulator |
| properties: |
| - configuration |
| NexmarkQueryTransform: |
| methods: |
| - getSideInput |
| - needsSideInput |
| - setSideInput |
| NexmarkQueryUtil: |
| methods: |
| - expand |
| - processElement |
| properties: |
| - AS_AUCTION |
| - AS_BID |
| - AS_PERSON |
| - AUCTION_BY_ID |
| - AUCTION_BY_SELLER |
| - AUCTION_TAG |
| - BID_BY_AUCTION |
| - BID_TAG |
| - BID_TO_AUCTION |
| - BID_TO_PRICE |
| - EVENT_TIMESTAMP_FROM_DATA |
| - IS_BID |
| - IS_NEW_AUCTION |
| - IS_NEW_PERSON |
| - JUST_BIDS |
| - JUST_NEW_AUCTIONS |
| - JUST_NEW_PERSONS |
| - PERSON_BY_ID |
| - PERSON_TAG |
| NexmarkUtils: |
| methods: |
| - apply |
| - batchEventsSource |
| - castToKnownSize |
| - cleanUpSideInput |
| - console |
| - cpuDelay |
| - decode |
| - devNull |
| - diskBusy |
| - encode |
| - expand |
| - format |
| - hash |
| - info |
| - interEventDelayUs |
| - log |
| - prepareSideInput |
| - processElement |
| - processingMode |
| - rateToPeriodUs |
| - setupPipeline |
| - snoop |
| - stamp |
| - standardEventIterator |
| - stepLengthSec |
| - streamEventsSource |
| properties: |
| - BEGINNING_OF_TIME |
| - END_OF_TIME |
| - MAPPER |
| - PUBSUB_ID |
| - PUBSUB_TIMESTAMP |
| NoSuchSchemaException: {} |
| NodeStats: |
| methods: |
| - create |
| - getRate |
| - getRowCount |
| - getWindow |
| - isUnknown |
| - minus |
| - multiply |
| - plus |
| properties: |
| - UNKNOWN |
| NonMergingWindowFn: |
| methods: |
| - isNonMerging |
| - mergeWindows |
| NoopCredentialFactory: |
| methods: |
| - fromOptions |
| - getAuthenticationType |
| - getCredential |
| - getRequestMetadata |
| - hasRequestMetadata |
| - hasRequestMetadataOnly |
| - refresh |
| NoopLock: |
| methods: |
| - get |
| - lock |
| - lockInterruptibly |
| - newCondition |
| - tryLock |
| - unlock |
| NoopPathValidator: |
| methods: |
| - fromOptions |
| - validateInputFilePatternSupported |
| - validateOutputFilePrefixSupported |
| - validateOutputResourceSupported |
| - verifyPath |
| NullCredentialInitializer: |
| methods: |
| - handleResponse |
| - initialize |
| - throwNullCredentialException |
| NullThroughputEstimator: |
| methods: |
| - getFrom |
| - update |
| NullableCoder: |
| methods: |
| - consistentWithEquals |
| - decode |
| - encode |
| - getCoderArguments |
| - getEncodedTypeDescriptor |
| - getValueCoder |
| - isRegisterByteSizeObserverCheap |
| - of |
| - registerByteSizeObserver |
| - structuralValue |
| - verifyDeterministic |
| NumberedShardedFile: |
| methods: |
| - getFilePattern |
| - readFilesWithRetries |
| - toString |
| ObjectPool: |
| methods: |
| - equals |
| - hashCode |
| - pooledClientFactory |
| - release |
| - releaseByKey |
| - retain |
| OffsetBasedSource: |
| methods: |
| - advance |
| - allowsDynamicSplitting |
| - createSourceForSubrange |
| - getBytesPerOffset |
| - getCurrentSource |
| - getEndOffset |
| - getEstimatedSizeBytes |
| - getFractionConsumed |
| - getMaxEndOffset |
| - getMinBundleSize |
| - getSplitPointsConsumed |
| - getSplitPointsRemaining |
| - getStartOffset |
| - isDone |
| - isStarted |
| - populateDisplayData |
| - split |
| - splitAtFraction |
| - start |
| - toString |
| - validate |
| OffsetByteRangeCoder: |
| methods: |
| - decode |
| - encode |
| - getCoderProvider |
| OffsetRange: |
| methods: |
| - consistentWithEquals |
| - decode |
| - encode |
| - equals |
| - getEncodedTypeDescriptor |
| - getFrom |
| - getTo |
| - hashCode |
| - isRegisterByteSizeObserverCheap |
| - newTracker |
| - of |
| - split |
| - toString |
| OffsetRangeTracker: |
| methods: |
| - checkDone |
| - currentRestriction |
| - getFractionConsumed |
| - getPositionForFractionConsumed |
| - getProgress |
| - getSplitPointsProcessed |
| - getStartPosition |
| - getStopPosition |
| - isBounded |
| - isDone |
| - isStarted |
| - markDone |
| - toString |
| - tryClaim |
| - tryReturnRecordAt |
| - trySplit |
| - trySplitAtPosition |
| properties: |
| - OFFSET_INFINITY |
| OneOfType: |
| methods: |
| - create |
| - createValue |
| - equals |
| - getArgument |
| - getArgumentType |
| - getBaseType |
| - getCaseEnumType |
| - getCaseType |
| - getFieldType |
| - getIdentifier |
| - getOneOfSchema |
| - getValue |
| - hashCode |
| - toBaseType |
| - toInputType |
| - toString |
| properties: |
| - IDENTIFIER |
| OpenModuleAgent: |
| methods: |
| - premain |
| Operator: |
| methods: |
| - getName |
| - getOutputType |
| - toString |
| OperatorTransform: |
| methods: |
| - apply |
| - expand |
| - getOperator |
| OrFinallyTrigger: |
| methods: |
| - getMainTrigger |
| - getUntilTrigger |
| - getWatermarkThatGuaranteesFiring |
| - mayFinish |
| - toString |
| Order: |
| methods: |
| - equals |
| - getCustomerId |
| - getId |
| - hashCode |
| - setCustomerId |
| - setId |
| - toString |
| OrderKey: |
| methods: |
| - getDir |
| - getIndex |
| - getNullFirst |
| - of |
| OutboundObserverFactory: |
| methods: |
| - clientBuffered |
| - clientDirect |
| - outboundObserverFor |
| - serverDirect |
| - trivial |
| PAssert: |
| methods: |
| - apply |
| - assertFor |
| - containsInAnyOrder |
| - countAsserts |
| - empty |
| - enterCompositeTransform |
| - equals |
| - expand |
| - from |
| - hashCode |
| - inCombinedNonLatePanes |
| - inEarlyGlobalWindowPanes |
| - inEarlyPane |
| - inFinalPane |
| - inLatePane |
| - inOnTimePane |
| - inOnlyPane |
| - inWindow |
| - isEqualTo |
| - leaveCompositeTransform |
| - notEqualTo |
| - of |
| - prepareActuals |
| - processElement |
| - satisfies |
| - that |
| - thatFlattened |
| - thatList |
| - thatMap |
| - thatMultimap |
| - thatSingleton |
| - thatSingletonIterable |
| - visitPrimitiveTransform |
| - windowActuals |
| - windowDummy |
| - wrap |
| properties: |
| - FAILURE_COUNTER |
| - SUCCESS_COUNTER |
| PBegin: |
| methods: |
| - apply |
| - expand |
| - getPipeline |
| - in |
| PCollection: |
| methods: |
| - and |
| - apply |
| - createPrimitiveOutputInternal |
| - expand |
| - finishSpecifying |
| - finishSpecifyingOutput |
| - getCoder |
| - getFromRowFunction |
| - getName |
| - getSchema |
| - getToRowFunction |
| - getTypeDescriptor |
| - getWindowingStrategy |
| - hasSchema |
| - isBounded |
| - setCoder |
| - setIsBoundedInternal |
| - setName |
| - setRowSchema |
| - setSchema |
| - setTypeDescriptor |
| - setWindowingStrategyInternal |
| PCollectionConsumerRegistry: |
| methods: |
| - accept |
| - finishLazyUpdate |
| - forConsumer |
| - getConsumer |
| - getExecutionState |
| - getMetricsContainer |
| - getMultiplexingConsumer |
| - getPTransformId |
| - getProgress |
| - register |
| - trySplit |
| - tryUpdate |
| PCollectionList: |
| methods: |
| - and |
| - apply |
| - empty |
| - equals |
| - expand |
| - finishSpecifyingOutput |
| - get |
| - getAll |
| - getPipeline |
| - hashCode |
| - of |
| - size |
| PCollectionLists: |
| methods: |
| - getOnlyElement |
| PCollectionRowTuple: |
| methods: |
| - and |
| - apply |
| - empty |
| - equals |
| - expand |
| - finishSpecifyingOutput |
| - get |
| - getAll |
| - getPipeline |
| - has |
| - hashCode |
| - of |
| PCollectionTuple: |
| methods: |
| - and |
| - apply |
| - empty |
| - equals |
| - expand |
| - finishSpecifyingOutput |
| - get |
| - getAll |
| - getPipeline |
| - has |
| - hashCode |
| - of |
| - ofPrimitiveOutputsInternal |
| PCollectionViews: |
| methods: |
| - apply |
| - compare |
| - contains |
| - containsKey |
| - create |
| - createMetadata |
| - decode |
| - encode |
| - entrySet |
| - equals |
| - expand |
| - get |
| - getCoderArguments |
| - getCoderInternal |
| - getDefaultValue |
| - getMaterialization |
| - getMetadata |
| - getPCollection |
| - getTagInternal |
| - getTypeDescriptor |
| - getViewFn |
| - getWindowMappingFn |
| - getWindowingStrategyInternal |
| - hasDefault |
| - hashCode |
| - isMetadata |
| - iterableView |
| - iterableViewUsingVoidKey |
| - iterator |
| - listIterator |
| - listView |
| - listViewUsingVoidKey |
| - mapView |
| - mapViewUsingVoidKey |
| - multimapView |
| - multimapViewUsingVoidKey |
| - singletonView |
| - singletonViewUsingVoidKey |
| - size |
| - toAdditionalInputs |
| - toString |
| - verifyDeterministic |
| PDone: |
| methods: |
| - expand |
| - finishSpecifyingOutput |
| - getPipeline |
| - in |
| POJOUtils: |
| methods: |
| - appender |
| - createConstructorCreator |
| - createStaticCreator |
| - getConstructorCreator |
| - getFieldTypes |
| - getGetters |
| - getSetFieldCreator |
| - getSetters |
| - getStaticCreator |
| - prepare |
| - schemaFromPojoClass |
| properties: |
| - CACHED_CREATORS |
| PTransform: |
| methods: |
| - compose |
| - expand |
| - getAdditionalInputs |
| - getDefaultOutputCoder |
| - getName |
| - getResourceHints |
| - populateDisplayData |
| - setResourceHints |
| - toString |
| - validate |
| PTransformFunctionRegistry: |
| methods: |
| - getFunctions |
| - register |
| PTransformOverride: |
| methods: |
| - getMatcher |
| - getOverrideFactory |
| - of |
| PValueBase: |
| methods: |
| - finishSpecifying |
| - finishSpecifyingOutput |
| - getName |
| - getPipeline |
| - setName |
| - toString |
| PValues: |
| methods: |
| - expandInput |
| - expandOutput |
| - expandValue |
| - fullyExpand |
| PaneInfo: |
| methods: |
| - createPane |
| - decode |
| - decodePane |
| - encode |
| - equals |
| - fromTag |
| - getIndex |
| - getNonSpeculativeIndex |
| - getTiming |
| - hashCode |
| - isFirst |
| - isLast |
| - isUnknown |
| - of |
| - toString |
| - verifyDeterministic |
| properties: |
| - INSTANCE |
| - NO_FIRING |
| - ON_TIME_AND_ONLY_FIRING |
| - tag |
| ParDo: |
| methods: |
| - dispatchBag |
| - dispatchCombining |
| - dispatchMap |
| - dispatchMultimap |
| - dispatchOrderedList |
| - dispatchSet |
| - dispatchValue |
| - expand |
| - getAdditionalInputs |
| - getAdditionalOutputTags |
| - getDoFnSchemaInformation |
| - getFn |
| - getMainOutputTag |
| - getSideInputs |
| - of |
| - populateDisplayData |
| - toString |
| - withOutputTags |
| - withSideInput |
| - withSideInputs |
| ParDoLoadTest: |
| methods: |
| - main |
| - processElement |
| ParquetIO: |
| methods: |
| - apply |
| - close |
| - create |
| - createOrOverwrite |
| - defaultBlockSize |
| - expand |
| - flush |
| - from |
| - getConfWithModelClass |
| - getInitialRestriction |
| - getLength |
| - getPos |
| - getProgress |
| - getRestrictionCoder |
| - getSize |
| - makeProgress |
| - newStream |
| - newTracker |
| - open |
| - parseFilesGenericRecords |
| - parseGenericRecords |
| - populateDisplayData |
| - processElement |
| - read |
| - readFiles |
| - seek |
| - sink |
| - split |
| - splitBlockWithLimit |
| - supportsBlockSize |
| - withAvroDataModel |
| - withBeamSchemas |
| - withCoder |
| - withCompressionCodec |
| - withConfiguration |
| - withProjection |
| - withRowGroupSize |
| - write |
| ParquetTableProvider: |
| methods: |
| - buildBeamSqlTable |
| - getTableType |
| ParseException: {} |
| ParseJsons: |
| methods: |
| - apply |
| - exceptionsInto |
| - exceptionsVia |
| - expand |
| - of |
| - withMapper |
| ParseResult: |
| methods: |
| - equals |
| - failure |
| - getContent |
| - getError |
| - getErrorAsString |
| - getFileLocation |
| - getMetadata |
| - hashCode |
| - isSuccess |
| - success |
| - toString |
| Partition: |
| methods: |
| - expand |
| - getOutputTags |
| - getSideInputs |
| - of |
| - populateDisplayData |
| - processElement |
| PartitionMetadata: |
| methods: |
| - build |
| - equals |
| - getCreatedAt |
| - getEndTimestamp |
| - getFinishedAt |
| - getHeartbeatMillis |
| - getParentTokens |
| - getPartitionToken |
| - getRunningAt |
| - getScheduledAt |
| - getStartTimestamp |
| - getState |
| - getWatermark |
| - hashCode |
| - newBuilder |
| - setCreatedAt |
| - setEndTimestamp |
| - setFinishedAt |
| - setHeartbeatMillis |
| - setParentTokens |
| - setPartitionToken |
| - setRunningAt |
| - setScheduledAt |
| - setStartTimestamp |
| - setState |
| - setWatermark |
| - toBuilder |
| - toString |
| PartitionMetadataAdminDao: |
| methods: |
| - createPartitionMetadataTable |
| - deletePartitionMetadataTable |
| properties: |
| - COLUMN_CREATED_AT |
| - COLUMN_END_TIMESTAMP |
| - COLUMN_FINISHED_AT |
| - COLUMN_HEARTBEAT_MILLIS |
| - COLUMN_PARENT_TOKENS |
| - COLUMN_PARTITION_TOKEN |
| - COLUMN_RUNNING_AT |
| - COLUMN_SCHEDULED_AT |
| - COLUMN_START_TIMESTAMP |
| - COLUMN_STATE |
| - COLUMN_WATERMARK |
| PartitionMetadataDao: |
| methods: |
| - countPartitionsCreatedAfter |
| - getAllPartitionsCreatedAfter |
| - getCommitTimestamp |
| - getPartition |
| - getResult |
| - getUnfinishedMinWatermark |
| - insert |
| - runInTransaction |
| - tableExists |
| - toString |
| - updateToFinished |
| - updateToRunning |
| - updateToScheduled |
| - updateWatermark |
| PartitionMetadataMapper: |
| methods: |
| - from |
| PartitionPosition: |
| methods: |
| - done |
| - equals |
| - getMode |
| - getTimestamp |
| - hashCode |
| - queryChangeStream |
| - stop |
| - toString |
| - updateState |
| - waitForChildPartitions |
| PartitionRestriction: |
| methods: |
| - done |
| - equals |
| - getEndTimestamp |
| - getMetadata |
| - getMode |
| - getStartTimestamp |
| - getStoppedMode |
| - hashCode |
| - queryChangeStream |
| - stop |
| - toString |
| - updateState |
| - waitForChildPartitions |
| - withMetadata |
| PartitionRestrictionClaimer: |
| methods: |
| - tryClaim |
| PartitionRestrictionMetadata: |
| methods: |
| - build |
| - getPartitionEndTimestamp |
| - getPartitionStartTimestamp |
| - getPartitionToken |
| - newBuilder |
| - toString |
| - withPartitionEndTimestamp |
| - withPartitionStartTimestamp |
| - withPartitionToken |
| PartitionRestrictionProgressChecker: |
| methods: |
| - getProgress |
| - setTimeSupplier |
| PartitionRestrictionSplitter: |
| methods: |
| - trySplit |
| PartitionRestrictionTracker: |
| methods: |
| - checkDone |
| - currentRestriction |
| - getProgress |
| - isBounded |
| - setTimeSupplier |
| - tryClaim |
| - trySplit |
| PartitioningWindowFn: |
| methods: |
| - assignWindow |
| - assignWindows |
| - assignsToOneWindow |
| - getDefaultWindowMappingFn |
| - getSideInputWindow |
| PassThroughLogicalType: |
| methods: |
| - getArgument |
| - getArgumentType |
| - getBaseType |
| - getIdentifier |
| - toBaseType |
| - toInputType |
| PatternCondition: |
| methods: |
| - eval |
| PayloadSerializerKafkaTable: |
| methods: |
| - expand |
| PayloadSerializers: |
| methods: |
| - getSerializer |
| PeriodicImpulse: |
| methods: |
| - applyWindowing |
| - create |
| - expand |
| - startAt |
| - stopAt |
| - withInterval |
| PeriodicSequence: |
| methods: |
| - checkDone |
| - create |
| - currentRestriction |
| - equals |
| - expand |
| - getInitialRange |
| - getInitialWatermarkState |
| - getProgress |
| - hashCode |
| - isBounded |
| - newTracker |
| - newWatermarkEstimator |
| - processElement |
| - toString |
| - tryClaim |
| - trySplit |
| properties: |
| - durationMilliSec |
| - first |
| - last |
| Person: |
| methods: |
| - decode |
| - encode |
| - equals |
| - hasAnnotation |
| - hashCode |
| - sizeInBytes |
| - structuralValue |
| - toString |
| - verifyDeterministic |
| - withAnnotation |
| - withoutAnnotation |
| properties: |
| - CODER |
| - city |
| - creditCard |
| - dateTime |
| - emailAddress |
| - extra |
| - id |
| - name |
| - state |
| PersonGenerator: |
| methods: |
| - lastBase0PersonId |
| - nextBase0PersonId |
| - nextPerson |
| Pipeline: |
| methods: |
| - apply |
| - applyTransform |
| - begin |
| - create |
| - enterCompositeTransform |
| - enterPipeline |
| - forTransformHierarchy |
| - getCoderRegistry |
| - getOptions |
| - getSchemaRegistry |
| - leaveCompositeTransform |
| - leavePipeline |
| - replaceAll |
| - run |
| - setCoderRegistry |
| - toString |
| - traverseTopologically |
| - visitPrimitiveTransform |
| - visitValue |
| PipelineOptionsFactory: |
| methods: |
| - apply |
| - as |
| - compare |
| - create |
| - describe |
| - fromArgs |
| - getRegisteredOptions |
| - printHelp |
| - register |
| - resetCache |
| - withValidation |
| - withoutStrictParsing |
| PipelineOptionsValidator: |
| methods: |
| - validate |
| - validateCli |
| PipelineRunner: |
| methods: |
| - create |
| - fromOptions |
| - run |
| Plugin: |
| methods: |
| - build |
| - builder |
| - createBatch |
| - createStreaming |
| - getContext |
| - getFormatClass |
| - getFormatProviderClass |
| - getGetOffsetFn |
| - getGetReceiverArgsFromConfigFn |
| - getHadoopConfiguration |
| - getPluginClass |
| - getPluginConfig |
| - getPluginType |
| - getReceiverBuilder |
| - getReceiverClass |
| - initContext |
| - initPluginType |
| - isUnbounded |
| - prepareRun |
| - setContext |
| - setFormatClass |
| - setFormatProviderClass |
| - setGetOffsetFn |
| - setGetReceiverArgsFromConfigFn |
| - setPluginClass |
| - setPluginType |
| - setReceiverClass |
| - withConfig |
| - withHadoopConfiguration |
| PluginConfigInstantiationUtils: {} |
| PluginConstants: |
| methods: |
| - getFormatClass |
| - getFormatName |
| - getFormatProviderClass |
| - getFormatProviderName |
| - getKeyClass |
| - getValueClass |
| PostProcessingMetricsDoFn: |
| methods: |
| - processElement |
| PrecombineGroupingTable: |
| methods: |
| - add |
| - combining |
| - combiningAndSampling |
| - compact |
| - equals |
| - estimateSize |
| - flush |
| - getAccumulator |
| - getGroupingKey |
| - getKey |
| - getOutputTimestamp |
| - getStructuralKey |
| - getWeight |
| - getWindows |
| - hashCode |
| - put |
| - shrink |
| - toString |
| PrecombineGroupingTableBenchmark: |
| methods: |
| - setUp |
| - sumIntegerBinaryCombine |
| properties: |
| - distribution |
| - globallyWindowed |
| Preconditions: |
| methods: |
| - checkArgumentNotNull |
| - checkStateNotNull |
| PrefetchableIterables: |
| methods: |
| - concat |
| - createIterator |
| - emptyIterable |
| - fromArray |
| - hasNext |
| - isReady |
| - iterator |
| - limit |
| - next |
| - prefetch |
| PrefetchableIterators: |
| methods: |
| - concat |
| - concatIterators |
| - emptyIterator |
| - fromArray |
| - hasNext |
| - isReady |
| - next |
| - prefetch |
| PrepareWrite: |
| methods: |
| - expand |
| - processElement |
| PriceGenerator: |
| methods: |
| - nextPrice |
| ProcessBundleBenchmark: |
| methods: |
| - getCacheTokens |
| - handle |
| - log |
| - process |
| - tearDown |
| - testLargeBundle |
| - testStateWithCaching |
| - testStateWithoutCaching |
| - testTinyBundle |
| ProcessBundleHandler: |
| methods: |
| - activate |
| - addBundleProgressReporter |
| - addFinishBundleFunction |
| - addIncomingDataEndpoint |
| - addIncomingTimerEndpoint |
| - addOutgoingDataEndpoint |
| - addOutgoingTimersEndpoint |
| - addPCollectionConsumer |
| - addResetFunction |
| - addStartBundleFunction |
| - addTearDownFunction |
| - afterBundleCommit |
| - close |
| - create |
| - createRunnerForPTransform |
| - find |
| - getActiveBundleProcessors |
| - getBeamFnDataClient |
| - getBeamFnStateClient |
| - getBundleCacheSupplier |
| - getBundleFinalizer |
| - getBundleProcessorCache |
| - getCacheTokensSupplier |
| - getCoders |
| - getPCollectionConsumer |
| - getPCollections |
| - getPTransform |
| - getPTransformId |
| - getPipelineOptions |
| - getProcessBundleInstructionIdSupplier |
| - getProcessWideCache |
| - getRunnerCapabilities |
| - getShortIdMap |
| - getSplitListener |
| - getStateTracker |
| - getWindowingStrategies |
| - handle |
| - hashCode |
| - load |
| - processBundle |
| - progress |
| - reset |
| - shutdown |
| - start |
| - trySplit |
| properties: |
| - JAVA_SOURCE_URN |
| ProducerRecordCoder: |
| methods: |
| - consistentWithEquals |
| - decode |
| - encode |
| - getCoderArguments |
| - isRegisterByteSizeObserverCheap |
| - of |
| - structuralValue |
| - verifyDeterministic |
| ProtoCoder: |
| methods: |
| - coderFor |
| - decode |
| - encode |
| - equals |
| - getCoderProvider |
| - getExtensionHosts |
| - getExtensionRegistry |
| - getMessageType |
| - hashCode |
| - of |
| - verifyDeterministic |
| - withExtensionsFrom |
| properties: |
| - serialVersionUID |
| ProtoDomain: |
| methods: |
| - buildFrom |
| - contains |
| - equals |
| - getDescriptor |
| - getFieldOptionById |
| - getFileDescriptor |
| - hashCode |
| properties: |
| - serialVersionUID |
| ProtoDynamicMessageSchema: |
| methods: |
| - apply |
| - forDescriptor |
| - getBaseClass |
| - getFromRowFunction |
| - getSchema |
| - getSubContext |
| - getToRowFunction |
| - invokeNewBuilder |
| properties: |
| - serialVersionUID |
| ProtoFromBytes: |
| methods: |
| - apply |
| - expand |
| ProtoMessageSchema: |
| methods: |
| - fieldValueGetters |
| - fieldValueTypeInformations |
| - get |
| - getProtoBytesToRowFn |
| - getRowToProtoBytesFn |
| - schemaFor |
| - schemaTypeCreator |
| ProtoPayloadSerializerProvider: |
| methods: |
| - getSerializer |
| - identifier |
| ProtoSchemaLogicalTypes: |
| methods: |
| - toDuration |
| - toRow |
| - toTimestamp |
| properties: |
| - IDENTIFIER |
| ProtoToBytes: |
| methods: |
| - apply |
| - expand |
| ProtobufCoderProviderRegistrar: |
| methods: |
| - getCoderProviders |
| Providers: |
| methods: |
| - loadProviders |
| PubSubPayloadTranslation: |
| methods: |
| - getTransformPayloadTranslators |
| - getUrn |
| - translate |
| PublishResponseCoders: |
| methods: |
| - decode |
| - defaultPublishResponse |
| - encode |
| - fullPublishResponse |
| - fullPublishResponseWithoutHeaders |
| - verifyDeterministic |
| PublishResultCoders: |
| methods: |
| - decode |
| - defaultPublishResult |
| - encode |
| - fullPublishResult |
| - fullPublishResultWithoutHeaders |
| - verifyDeterministic |
| PublisherOptions: |
| methods: |
| - build |
| - newBuilder |
| - setTopicPath |
| - topicPath |
| PubsubClient: |
| methods: |
| - ackDeadlineSeconds |
| - ackId |
| - acknowledge |
| - apply |
| - createRandomSubscription |
| - createSchema |
| - createSubscription |
| - createTopic |
| - deleteSchema |
| - deleteSubscription |
| - deleteTopic |
| - equals |
| - getFullPath |
| - getId |
| - getName |
| - getPath |
| - getProjectId |
| - getSchema |
| - getSchemaPath |
| - hashCode |
| - isEOF |
| - listSubscriptions |
| - listTopics |
| - message |
| - modifyAckDeadline |
| - of |
| - projectPathFromId |
| - projectPathFromPath |
| - publish |
| - pull |
| - recordId |
| - requestTimeMsSinceEpoch |
| - schemaPathFromId |
| - schemaPathFromPath |
| - subscriptionPathFromName |
| - subscriptionPathFromPath |
| - timestampMsSinceEpoch |
| - toString |
| - topicPathFromName |
| - topicPathFromPath |
| PubsubCoderProviderRegistrar: |
| methods: |
| - getCoderProviders |
| PubsubDlqProvider: |
| methods: |
| - expand |
| - identifier |
| - newDlqTransform |
| PubsubGrpcClient: |
| methods: |
| - ackDeadlineSeconds |
| - acknowledge |
| - close |
| - createSchema |
| - createSubscription |
| - createTopic |
| - deleteSchema |
| - deleteSubscription |
| - deleteTopic |
| - getKind |
| - getSchema |
| - getSchemaPath |
| - isEOF |
| - listSubscriptions |
| - listTopics |
| - modifyAckDeadline |
| - newClient |
| - publish |
| - pull |
| properties: |
| - FACTORY |
| PubsubHelper: |
| methods: |
| - cleanup |
| - create |
| - createOrReuseTopic |
| - createSubscription |
| - createTopic |
| - reuseSubscription |
| - reuseTopic |
| - subscriptionExists |
| - topicExists |
| PubsubIO: |
| methods: |
| - apply |
| - asPath |
| - asV1Beta1Path |
| - asV1Beta2Path |
| - expand |
| - finishBundle |
| - fromPath |
| - fromSubscription |
| - fromTopic |
| - populateDisplayData |
| - processElement |
| - readAvroGenericRecords |
| - readAvros |
| - readAvrosWithBeamSchema |
| - readMessages |
| - readMessagesWithAttributes |
| - readMessagesWithAttributesAndMessageId |
| - readMessagesWithAttributesAndMessageIdAndOrderingKey |
| - readMessagesWithCoderAndParseFn |
| - readMessagesWithMessageId |
| - readProtoDynamicMessages |
| - readProtos |
| - readStrings |
| - startBundle |
| - to |
| - toString |
| - withClientFactory |
| - withCoderAndParseFn |
| - withDeadLetterTopic |
| - withIdAttribute |
| - withMaxBatchBytesSize |
| - withMaxBatchSize |
| - withPubsubRootUrl |
| - withTimestampAttribute |
| - writeAvros |
| - writeMessages |
| - writeProtos |
| - writeStrings |
| PubsubJsonClient: |
| methods: |
| - ackDeadlineSeconds |
| - acknowledge |
| - close |
| - createSchema |
| - createSubscription |
| - createTopic |
| - deleteSchema |
| - deleteSubscription |
| - deleteTopic |
| - getKind |
| - getSchema |
| - getSchemaPath |
| - isEOF |
| - listSubscriptions |
| - listTopics |
| - modifyAckDeadline |
| - newClient |
| - publish |
| - pull |
| properties: |
| - FACTORY |
| PubsubLiteIO: |
| methods: |
| - addUuids |
| - deduplicate |
| - expand |
| - read |
| - write |
| PubsubLiteSink: |
| methods: |
| - finishBundle |
| - processElement |
| - startBundle |
| PubsubLiteTableProvider: |
| methods: |
| - buildBeamSqlTable |
| - getTableType |
| PubsubMessage: |
| methods: |
| - equals |
| - getAttribute |
| - getAttributeMap |
| - getMessageId |
| - getOrderingKey |
| - getPayload |
| - hashCode |
| - toString |
| PubsubMessagePayloadOnlyCoder: |
| methods: |
| - decode |
| - encode |
| - of |
| PubsubMessageWithAttributesAndMessageIdAndOrderingKeyCoder: |
| methods: |
| - decode |
| - encode |
| - of |
| PubsubMessageWithAttributesAndMessageIdCoder: |
| methods: |
| - decode |
| - encode |
| - of |
| PubsubMessageWithAttributesCoder: |
| methods: |
| - decode |
| - encode |
| - of |
| PubsubMessageWithMessageIdCoder: |
| methods: |
| - decode |
| - encode |
| - of |
| PubsubMessages: |
| methods: |
| - apply |
| - fromProto |
| - toProto |
| PubsubSchemaIOProvider: |
| methods: |
| - buildReader |
| - buildWriter |
| - configurationSchema |
| - expand |
| - from |
| - identifier |
| - isBounded |
| - requiresDataSchema |
| - schema |
| properties: |
| - ATTRIBUTE_ARRAY_ENTRY_SCHEMA |
| - ATTRIBUTE_ARRAY_FIELD_TYPE |
| - ATTRIBUTE_MAP_FIELD_TYPE |
| PubsubSchemaTransformReadConfiguration: |
| methods: |
| - build |
| - builder |
| - getDataSchema |
| - getDeadLetterQueue |
| - getFormat |
| - getIdAttribute |
| - getProtoClass |
| - getSubscription |
| - getThriftClass |
| - getThriftProtocolFactoryClass |
| - getTimestampAttribute |
| - getTopic |
| - setDataSchema |
| - setDeadLetterQueue |
| - setFormat |
| - setIdAttribute |
| - setProtoClass |
| - setSubscription |
| - setThriftClass |
| - setThriftProtocolFactoryClass |
| - setTimestampAttribute |
| - setTopic |
| PubsubSchemaTransformReadProvider: |
| methods: |
| - buildTransform |
| - expand |
| - identifier |
| - inputCollectionNames |
| - outputCollectionNames |
| - validate |
| PubsubTableProvider: |
| methods: |
| - getSchemaIOProvider |
| - getTableType |
| PubsubTestClient: |
| methods: |
| - ackDeadlineSeconds |
| - acknowledge |
| - advance |
| - close |
| - createFactoryForCreateSubscription |
| - createFactoryForGetSchema |
| - createFactoryForPublish |
| - createFactoryForPull |
| - createFactoryForPullAndPublish |
| - createSchema |
| - createSubscription |
| - createTopic |
| - deleteSchema |
| - deleteSubscription |
| - deleteTopic |
| - getKind |
| - getSchema |
| - getSchemaPath |
| - isEOF |
| - listSubscriptions |
| - listTopics |
| - modifyAckDeadline |
| - newClient |
| - publish |
| - pull |
| PubsubUnboundedSink: |
| methods: |
| - decode |
| - encode |
| - expand |
| - finishBundle |
| - getIdAttribute |
| - getTimestampAttribute |
| - getTopic |
| - getTopicProvider |
| - populateDisplayData |
| - processElement |
| - startBundle |
| properties: |
| - outer |
| PubsubUnboundedSource: |
| methods: |
| - advance |
| - apply |
| - close |
| - createReader |
| - decode |
| - encode |
| - expand |
| - finalizeCheckpoint |
| - getCheckpointMark |
| - getCheckpointMarkCoder |
| - getCurrent |
| - getCurrentRecordId |
| - getCurrentSource |
| - getCurrentTimestamp |
| - getIdAttribute |
| - getNeedsAttributes |
| - getNeedsMessageId |
| - getNeedsOrderingKey |
| - getOutputCoder |
| - getProject |
| - getSplitBacklogBytes |
| - getSubscription |
| - getSubscriptionProvider |
| - getTimestampAttribute |
| - getTopic |
| - getTopicProvider |
| - getWatermark |
| - identity |
| - nackAll |
| - nackBatch |
| - of |
| - populateDisplayData |
| - processElement |
| - requiresDeduping |
| - split |
| - start |
| - validate |
| properties: |
| - outer |
| PubsubWriteSchemaTransformConfiguration: |
| methods: |
| - build |
| - builder |
| - getAttributesFieldName |
| - getFormat |
| - getIdAttribute |
| - getPayloadFieldName |
| - getSource |
| - getTarget |
| - getTimestampAttributeKey |
| - getTimestampFieldName |
| - getTopic |
| - setAttributesFieldName |
| - setFormat |
| - setIdAttribute |
| - setPayloadFieldName |
| - setSource |
| - setTarget |
| - setTimestampAttributeKey |
| - setTimestampFieldName |
| - setTopic |
| - sourceConfigurationBuilder |
| - targetConfigurationBuilder |
| properties: |
| - DEFAULT_TIMESTAMP_ATTRIBUTE |
| PubsubWriteSchemaTransformProvider: |
| methods: |
| - buildTransform |
| - expand |
| - identifier |
| - inputCollectionNames |
| - outputCollectionNames |
| - process |
| PulsarIO: |
| methods: |
| - expand |
| - read |
| - useProcessingTime |
| - usePublishTime |
| - withAdminUrl |
| - withClientUrl |
| - withEndMessageId |
| - withEndTimestamp |
| - withExtractOutputTimestampFn |
| - withProcessingTime |
| - withPublishTime |
| - withPulsarClient |
| - withStartTimestamp |
| - withTopic |
| - write |
| PulsarMessage: |
| methods: |
| - getMessageRecord |
| - getPublishTimestamp |
| - getTopic |
| - setMessageRecord |
| PulsarMessageCoder: |
| methods: |
| - decode |
| - encode |
| - of |
| PulsarSourceDescriptor: |
| methods: |
| - of |
| PythonCallable: |
| methods: |
| - getArgumentType |
| - getBaseType |
| - getIdentifier |
| - toBaseType |
| - toInputType |
| properties: |
| - IDENTIFIER |
| PythonCallableSource: |
| methods: |
| - getPythonCallableCode |
| - of |
| PythonExternalTransform: |
| methods: |
| - expand |
| - from |
| - withArgs |
| - withExtraPackages |
| - withKwarg |
| - withKwargs |
| - withOutputCoder |
| - withOutputCoders |
| - withTypeHint |
| PythonMap: |
| methods: |
| - expand |
| - viaFlatMapFn |
| - viaMapFn |
| - withExpansionService |
| PythonService: |
| methods: |
| - findAvailablePort |
| - start |
| - waitForPort |
| - withExtraPackages |
| Quantifier: |
| methods: |
| - toString |
| properties: |
| - ASTERISK |
| - ASTERISK_RELUCTANT |
| - NONE |
| - PLUS |
| - PLUS_RELUCTANT |
| - QMARK |
| - QMARK_RELUCTANT |
| Query0: |
| methods: |
| - expand |
| - processElement |
| Query0Model: |
| methods: |
| - simulator |
| Query1: |
| methods: |
| - expand |
| - processElement |
| Query10: |
| methods: |
| - expand |
| - processElement |
| - setMaxNumWorkers |
| - setOutputPath |
| - toString |
| Query11: |
| methods: |
| - expand |
| - processElement |
| Query12: |
| methods: |
| - expand |
| - processElement |
| Query13: |
| methods: |
| - expand |
| - processElement |
| Query14: |
| methods: |
| - expand |
| Query1Model: |
| methods: |
| - simulator |
| Query2: |
| methods: |
| - expand |
| - processElement |
| Query2Model: |
| methods: |
| - simulator |
| Query3: |
| methods: |
| - expand |
| - onTimerCallback |
| - processElement |
| Query3Model: |
| methods: |
| - simulator |
| Query4: |
| methods: |
| - expand |
| - processElement |
| Query4Model: |
| methods: |
| - simulator |
| Query5: |
| methods: |
| - addInput |
| - createAccumulator |
| - equals |
| - expand |
| - extractOutput |
| - getAccumulatorCoder |
| - hashCode |
| - mergeAccumulator |
| - processElement |
| properties: |
| - auctions |
| - count |
| Query5Model: |
| methods: |
| - run |
| - simulator |
| Query6: |
| methods: |
| - addInput |
| - createAccumulator |
| - expand |
| - extractOutput |
| - mergeAccumulators |
| - processElement |
| Query6Model: |
| methods: |
| - simulator |
| Query7: |
| methods: |
| - expand |
| - processElement |
| Query7Model: |
| methods: |
| - simulator |
| Query8: |
| methods: |
| - expand |
| - processElement |
| Query8Model: |
| methods: |
| - run |
| - simulator |
| Query9: |
| methods: |
| - expand |
| Query9Model: |
| methods: |
| - simulator |
| QueryChangeStreamAction: |
| methods: |
| - run |
| QueryReader: |
| methods: |
| - getQueryIdentifiers |
| - readQuery |
| QueryStatementConverter: |
| methods: |
| - convert |
| - convertRootQuery |
| QueryTrait: |
| methods: |
| - addOutputColumnList |
| - addResolvedTable |
| - getTablePath |
| - isTableResolved |
| - resolveAlias |
| - retrieveFieldNames |
| properties: |
| - outputColumnMap |
| - resolvedTables |
| - withEntries |
| RabbitMqIO: |
| methods: |
| - advance |
| - advanceWatermark |
| - close |
| - createReader |
| - expand |
| - finalizeCheckpoint |
| - getChannel |
| - getCheckpointMark |
| - getCheckpointMarkCoder |
| - getCurrent |
| - getCurrentRecordId |
| - getCurrentSource |
| - getCurrentTimestamp |
| - getOutputCoder |
| - getWatermark |
| - processElement |
| - read |
| - requiresDeduping |
| - setup |
| - split |
| - start |
| - stop |
| - teardown |
| - withExchange |
| - withMaxNumRecords |
| - withMaxReadTime |
| - withQueue |
| - withQueueDeclare |
| - withUri |
| - withUseCorrelationId |
| - write |
| RabbitMqMessage: |
| methods: |
| - createProperties |
| - equals |
| - getAppId |
| - getBody |
| - getClusterId |
| - getContentEncoding |
| - getContentType |
| - getCorrelationId |
| - getDeliveryMode |
| - getExpiration |
| - getHeaders |
| - getMessageId |
| - getPriority |
| - getReplyTo |
| - getRoutingKey |
| - getTimestamp |
| - getType |
| - getUserId |
| - hashCode |
| RampupThrottlingFn: |
| methods: |
| - populateDisplayData |
| - processElement |
| - setup |
| RawUnionValue: |
| methods: |
| - equals |
| - getUnionTag |
| - getValue |
| - hashCode |
| - toString |
| Read: |
| methods: |
| - advance |
| - checkDone |
| - close |
| - create |
| - createReader |
| - currentRestriction |
| - decode |
| - encode |
| - expand |
| - from |
| - getCheckpoint |
| - getCheckpointMark |
| - getCheckpointMarkCoder |
| - getCoderArguments |
| - getCurrent |
| - getCurrentSource |
| - getCurrentTimestamp |
| - getId |
| - getInitialWatermarkEstimatorState |
| - getKindString |
| - getProgress |
| - getSize |
| - getSource |
| - getTimestamp |
| - getValue |
| - getWatermark |
| - initialRestriction |
| - isBounded |
| - newWatermarkEstimator |
| - populateDisplayData |
| - processElement |
| - restrictionCoder |
| - restrictionTracker |
| - setUp |
| - split |
| - splitRestriction |
| - start |
| - tryClaim |
| - trySplit |
| - verifyDeterministic |
| - withMaxNumRecords |
| - withMaxReadTime |
| ReadAllViaFileBasedSource: |
| methods: |
| - apply |
| - expand |
| - process |
| properties: |
| - DEFAULT_USES_RESHUFFLE |
| ReadBuilder: |
| methods: |
| - buildExternal |
| - getCsvMapper |
| ReadChangeStreamPartitionDoFn: |
| methods: |
| - getInitialWatermarkEstimatorState |
| - getSize |
| - initialRestriction |
| - newTracker |
| - newWatermarkEstimator |
| - processElement |
| - setThroughputEstimator |
| - setup |
| ReadChangeStreamPartitionRangeTracker: |
| methods: |
| - tryClaim |
| - trySplit |
| ReadFromPulsarDoFn: |
| methods: |
| - estimate |
| - getInitialRestriction |
| - getInitialWatermarkEstimatorState |
| - getRestrictionCoder |
| - getSize |
| - initPulsarClients |
| - newReader |
| - newWatermarkEstimator |
| - processElement |
| - restrictionTracker |
| - teardown |
| ReadOnlyTableProvider: |
| methods: |
| - buildBeamSqlTable |
| - createTable |
| - dropTable |
| - getTableType |
| - getTables |
| ReadOperation: |
| methods: |
| - create |
| - getColumns |
| - getIndex |
| - getKeySet |
| - getQuery |
| - getQueryName |
| - getTable |
| - withColumns |
| - withIndex |
| - withKeySet |
| - withPartitionOptions |
| - withQuery |
| - withQueryName |
| - withTable |
| ReadableFileCoder: |
| methods: |
| - decode |
| - encode |
| - getCoderArguments |
| - getMetadataCoder |
| - of |
| - verifyDeterministic |
| ReadableStates: |
| methods: |
| - immediate |
| - read |
| - readLater |
| ReaderDelay: |
| methods: |
| - delayRecord |
| - delayStart |
| ReceiverBuilder: |
| methods: |
| - build |
| - getSparkReceiverClass |
| - withConstructorArgs |
| RecommendationAICreateCatalogItem: |
| methods: |
| - build |
| - catalogName |
| - expand |
| - processElement |
| - projectId |
| - setCatalogName |
| - setProjectId |
| - withCatalogName |
| - withProjectId |
| properties: |
| - FAILURE_TAG |
| - SUCCESS_TAG |
| RecommendationAIIO: |
| methods: |
| - createCatalogItems |
| - importCatalogItems |
| - importUserEvents |
| - predictAll |
| - writeUserEvent |
| RecommendationAIImportCatalogItems: |
| methods: |
| - batchSize |
| - build |
| - catalogName |
| - expand |
| - maxBufferingDuration |
| - processElement |
| - projectId |
| - setBatchSize |
| - setCatalogName |
| - setMaxBufferingDuration |
| - setProjectId |
| - withBatchSize |
| - withCatalogName |
| - withProjectId |
| properties: |
| - FAILURE_TAG |
| - SUCCESS_TAG |
| RecommendationAIImportUserEvents: |
| methods: |
| - batchSize |
| - build |
| - catalogName |
| - eventStore |
| - expand |
| - maxBufferingDuration |
| - processElement |
| - projectId |
| - setBatchSize |
| - setCatalogName |
| - setEventStore |
| - setMaxBufferingDuration |
| - setProjectId |
| - withBatchSize |
| - withCatalogName |
| - withEventStore |
| - withProjectId |
| properties: |
| - FAILURE_TAG |
| - SUCCESS_TAG |
| RecommendationAIPredict: |
| methods: |
| - build |
| - catalogName |
| - eventStore |
| - expand |
| - placementId |
| - processElement |
| - projectId |
| - setCatalogName |
| - setEventStore |
| - setPlacementId |
| - setProjectId |
| - withCatalogName |
| - withEventStore |
| - withPlacementId |
| - withProjectId |
| properties: |
| - FAILURE_TAG |
| - SUCCESS_TAG |
| RecommendationAIWriteUserEvent: |
| methods: |
| - build |
| - catalogName |
| - eventStore |
| - expand |
| - processElement |
| - projectId |
| - setCatalogName |
| - setEventStore |
| - setProjectId |
| - withCatalogName |
| - withEventStore |
| - withProjectId |
| properties: |
| - FAILURE_TAG |
| - SUCCESS_TAG |
| RecordWithMetadata: |
| methods: |
| - getArgument |
| - getArgumentType |
| - getBaseType |
| - getIdentifier |
| - getSchema |
| - toBaseType |
| - toInputType |
| properties: |
| - RANGE_OFFSET |
| - RECORD_NUM |
| - RECORD_NUM_IN_OFFSET |
| - RECORD_OFFSET |
| - RESOURCE_ID |
| - VALUE |
| RedisConnectionConfiguration: |
| methods: |
| - connect |
| - create |
| - enableSSL |
| - populateDisplayData |
| - withAuth |
| - withHost |
| - withPort |
| - withSSL |
| - withTimeout |
| RedisCursor: |
| methods: |
| - compareTo |
| - equals |
| - getCursor |
| - getDbSize |
| - hashCode |
| - isStart |
| - of |
| properties: |
| - END_CURSOR |
| - ZERO_CURSOR |
| - ZERO_KEY |
| RedisIO: |
| methods: |
| - expand |
| - finishBundle |
| - getInitialRestriction |
| - populateDisplayData |
| - processElement |
| - read |
| - readKeyPatterns |
| - setup |
| - startBundle |
| - teardown |
| - withApproximateTrim |
| - withAuth |
| - withBatchSize |
| - withConnectionConfiguration |
| - withEndpoint |
| - withExpireTime |
| - withKeyPattern |
| - withMaxLen |
| - withMethod |
| - withOutputParallelization |
| - withTimeout |
| - write |
| - writeStreams |
| ReduceByKey: |
| methods: |
| - accumulationMode |
| - combineBy |
| - getAccumulate |
| - getAccumulatorFactory |
| - getAccumulatorType |
| - getMergeAccumulators |
| - getOutputFn |
| - getReducer |
| - getValueComparator |
| - getValueExtractor |
| - getValueType |
| - isCombinable |
| - isCombineFnStyle |
| - keyBy |
| - named |
| - of |
| - output |
| - outputValues |
| - reduceBy |
| - triggeredBy |
| - valueBy |
| - windowBy |
| - withAllowedLateness |
| - withOnTimeBehavior |
| - withSortedValues |
| - withTimestampCombiner |
| ReduceByKeyTranslator: |
| methods: |
| - addInput |
| - apply |
| - canTranslate |
| - createAccumulator |
| - extractOutput |
| - getAccumulatorCoder |
| - mergeAccumulators |
| - processElement |
| - translate |
| ReduceWindow: |
| methods: |
| - accumulationMode |
| - combineBy |
| - expand |
| - getReducer |
| - getValueComparator |
| - getValueExtractor |
| - getValueType |
| - isCombinable |
| - isCombineFnStyle |
| - named |
| - of |
| - output |
| - reduceBy |
| - triggeredBy |
| - valueBy |
| - windowBy |
| - withAllowedLateness |
| - withOnTimeBehavior |
| - withSortedValues |
| - withTimestampCombiner |
| ReflectHelpers: |
| methods: |
| - compare |
| - declaredFieldsWithAnnotation |
| - declaredMethodsWithAnnotation |
| - findClassLoader |
| - formatAnnotation |
| - formatMethod |
| - formatMethodWithClass |
| - getClosureOfMethodsOnInterface |
| - getClosureOfMethodsOnInterfaces |
| - loadServicesOrdered |
| - simpleTypeDescription |
| properties: |
| - INSTANCE |
| ReflectUtils: |
| methods: |
| - boxIfPrimitive |
| - create |
| - getAnnotatedConstructor |
| - getAnnotatedCreateMethod |
| - getClazz |
| - getFields |
| - getIterableComponentType |
| - getMapType |
| - getMethods |
| - getMethodsMap |
| - getSchema |
| - isGetter |
| - isSetter |
| - stripGetterPrefix |
| - stripPrefix |
| - stripSetterPrefix |
| Regex: |
| methods: |
| - allMatches |
| - expand |
| - find |
| - findAll |
| - findKV |
| - matches |
| - matchesKV |
| - processElement |
| - replaceAll |
| - replaceFirst |
| - split |
| RegexMatcher: |
| methods: |
| - describeTo |
| - matches |
| Reify: |
| methods: |
| - expand |
| - extractTimestampsFromValues |
| - getAllowedTimestampSkew |
| - process |
| - processElement |
| - timestamps |
| - timestampsInValue |
| - viewAsValues |
| - viewInGlobalWindow |
| - windows |
| - windowsInValue |
| ReifyAsIterable: |
| methods: |
| - expand |
| - processElement |
| RelMdNodeStats: |
| methods: |
| - getDef |
| - getNodeStats |
| properties: |
| - SOURCE |
| ReleaseInfo: |
| methods: |
| - getDefaultDockerRepoPrefix |
| - getDefaultDockerRepoRoot |
| - getName |
| - getProperties |
| - getReleaseInfo |
| - getSdkVersion |
| - getVersion |
| - isDevSdkVersion |
| RemoteGrpcPortRead: |
| methods: |
| - fromPTransform |
| - getPort |
| - readFromPort |
| - toPTransform |
| properties: |
| - URN |
| RemoteGrpcPortWrite: |
| methods: |
| - fromPTransform |
| - getPort |
| - toPTransform |
| - writeToPort |
| properties: |
| - URN |
| RenameFields: |
| methods: |
| - create |
| - expand |
| - processElement |
| - rename |
| Repeatedly: |
| methods: |
| - forever |
| - getRepeatedTrigger |
| - getWatermarkThatGuaranteesFiring |
| - mayFinish |
| - toString |
| Requirements: |
| methods: |
| - empty |
| - getSideInputs |
| - isEmpty |
| - requiresSideInputs |
| - union |
| Reshuffle: |
| methods: |
| - expand |
| - of |
| - processElement |
| - setup |
| - viaRandomKey |
| - withNumBuckets |
| ReshuffleTrigger: |
| methods: |
| - getWatermarkThatGuaranteesFiring |
| - mayFinish |
| - toString |
| ResourceHint: |
| methods: |
| - equals |
| - hashCode |
| - mergeWithOuter |
| - toBytes |
| ResourceHints: |
| methods: |
| - create |
| - equals |
| - fromOptions |
| - hashCode |
| - hints |
| - mergeWithOuter |
| - parse |
| - toBytes |
| - withAccelerator |
| - withHint |
| - withMinRam |
| ResourceIdCoder: |
| methods: |
| - consistentWithEquals |
| - decode |
| - encode |
| - of |
| ResourceIdTester: |
| methods: |
| - runResourceIdBattery |
| RestrictionTracker: |
| methods: |
| - checkDone |
| - currentRestriction |
| - from |
| - getTruncatedRestriction |
| - getWorkCompleted |
| - getWorkRemaining |
| - isBounded |
| - of |
| - tryClaim |
| - trySplit |
| RestrictionTrackers: |
| methods: |
| - checkDone |
| - currentRestriction |
| - getProgress |
| - isBounded |
| - observe |
| - tryClaim |
| - trySplit |
| RetryConfiguration: |
| methods: |
| - baseBackoff |
| - build |
| - builder |
| - convert |
| - maxBackoff |
| - numRetries |
| - throttledBaseBackoff |
| - toBuilder |
| RetryHttpRequestInitializer: |
| methods: |
| - handleIOException |
| - handleResponse |
| - initialize |
| - setCustomErrors |
| - setWriteTimeout |
| RightJoin: |
| methods: |
| - by |
| - named |
| - of |
| - using |
| RingRange: |
| methods: |
| - equals |
| - getEnd |
| - getStart |
| - hashCode |
| - isWrapping |
| - of |
| - toString |
| Row: |
| methods: |
| - addArray |
| - addIterable |
| - addValue |
| - addValues |
| - attachValues |
| - build |
| - deepEquals |
| - deepHashCode |
| - equals |
| - fromRow |
| - getArray |
| - getBaseValue |
| - getBaseValues |
| - getBoolean |
| - getByte |
| - getBytes |
| - getDateTime |
| - getDecimal |
| - getDouble |
| - getFieldCount |
| - getFloat |
| - getInt16 |
| - getInt32 |
| - getInt64 |
| - getIterable |
| - getLogicalTypeValue |
| - getMap |
| - getRow |
| - getSchema |
| - getString |
| - getValue |
| - getValues |
| - hashCode |
| - nextFieldId |
| - nullRow |
| - toRow |
| - toString |
| - withFieldAccessDescriptors |
| - withFieldValue |
| - withFieldValueGetters |
| - withFieldValues |
| - withSchema |
| RowBundle: |
| methods: |
| - processRows |
| - setup |
| RowCoder: |
| methods: |
| - equals |
| - hashCode |
| - of |
| - overrideEncodingPositions |
| RowCoderGenerator: |
| methods: |
| - appender |
| - generate |
| - overrideEncodingPositions |
| - prepare |
| RowJson: |
| methods: |
| - deserialize |
| - forSchema |
| - serialize |
| - toString |
| - verifySchemaSupported |
| - withDropNullsOnWrite |
| - withNullBehavior |
| RowJsonUtils: |
| methods: |
| - jsonToRow |
| - newObjectMapperWith |
| - rowToJson |
| RowMessages: |
| methods: |
| - apply |
| - bytesToRowFn |
| - rowToBytesFn |
| RowToCsv: |
| methods: |
| - expand |
| - getCsvFormat |
| RowToEntity: |
| methods: |
| - create |
| - createTest |
| - expand |
| - processElement |
| RowUtils: |
| methods: |
| - byteString |
| - byteStringUtf8 |
| properties: |
| - COLUMNS_MAPPING |
| - KEY |
| - LABELS |
| - TIMESTAMP_MICROS |
| - VALUE |
| RowWithGetters: |
| methods: |
| - equals |
| - getFieldCount |
| - getGetterTarget |
| - getGetters |
| - getValue |
| - getValues |
| - hashCode |
| RowWithStorage: |
| methods: |
| - getFieldCount |
| - getValue |
| - getValues |
| RpcQosOptions: |
| methods: |
| - build |
| - defaultOptions |
| - equals |
| - getBatchInitialCount |
| - getBatchMaxBytes |
| - getBatchMaxCount |
| - getBatchTargetLatency |
| - getHintMaxNumWorkers |
| - getInitialBackoff |
| - getMaxAttempts |
| - getOverloadRatio |
| - getSamplePeriod |
| - getSamplePeriodBucketSize |
| - getThrottleDuration |
| - hashCode |
| - isShouldReportDiagnosticMetrics |
| - newBuilder |
| - populateDisplayData |
| - toBuilder |
| - toString |
| - withBatchInitialCount |
| - withBatchMaxBytes |
| - withBatchMaxCount |
| - withBatchTargetLatency |
| - withHintMaxNumWorkers |
| - withInitialBackoff |
| - withMaxAttempts |
| - withOverloadRatio |
| - withReportDiagnosticMetrics |
| - withSamplePeriod |
| - withSamplePeriodBucketSize |
| - withThrottleDuration |
| RunInference: |
| methods: |
| - expand |
| - of |
| - ofKVs |
| - withExpansionService |
| - withExtraPackages |
| - withKwarg |
| S3FileSystemConfiguration: |
| methods: |
| - build |
| - builder |
| - builderFrom |
| - fromS3Options |
| - getBucketKeyEnabled |
| - getBuilder |
| - getS3ClientBuilder |
| - getS3StorageClass |
| - getS3ThreadPoolSize |
| - getS3UploadBufferSizeBytes |
| - getSSEAlgorithm |
| - getSSEAwsKeyManagementParams |
| - getSSECustomerKey |
| - getSSEKMSKeyId |
| - getScheme |
| - setBucketKeyEnabled |
| - setS3ClientBuilder |
| - setS3StorageClass |
| - setS3ThreadPoolSize |
| - setS3UploadBufferSizeBytes |
| - setSSEAlgorithm |
| - setSSEAwsKeyManagementParams |
| - setSSECustomerKey |
| - setSSEKMSKeyId |
| - setScheme |
| - toBuilder |
| properties: |
| - MINIMUM_UPLOAD_BUFFER_SIZE_BYTES |
| S3FileSystemRegistrar: |
| methods: |
| - fromOptions |
| SSECustomerKey: |
| methods: |
| - algorithm |
| - build |
| - builder |
| - getAlgorithm |
| - getKey |
| - getMD5 |
| - key |
| - md5 |
| Sample: |
| methods: |
| - addInput |
| - any |
| - anyCombineFn |
| - anyValueCombineFn |
| - combineFn |
| - createAccumulator |
| - expand |
| - extractOutput |
| - fixedSizeGlobally |
| - fixedSizePerKey |
| - getAccumulatorCoder |
| - getDefaultOutputCoder |
| - mergeAccumulators |
| - populateDisplayData |
| SbeLogicalTypes: |
| methods: |
| - getArgumentType |
| - getBaseType |
| - getIdentifier |
| - toBaseType |
| - toInputType |
| properties: |
| - IDENTIFIER |
| SbeSchema: |
| methods: |
| - assumeSingleMessageSchema |
| - build |
| - builder |
| - fromIr |
| - getIr |
| - getIrOptions |
| - getSbeFields |
| - messageId |
| - messageName |
| - setMessageId |
| - setMessageName |
| - toBuilder |
| properties: |
| - DEFAULT |
| ScalarFn: {} |
| ScalarFnReflector: |
| methods: |
| - getApplyMethod |
| ScalarFunctionImpl: |
| methods: |
| - create |
| - createAll |
| - getImplementor |
| - getJarPath |
| - getReturnType |
| - implement |
| Schema: |
| methods: |
| - addArrayField |
| - addBooleanField |
| - addByteArrayField |
| - addByteField |
| - addDateTimeField |
| - addDecimalField |
| - addDoubleField |
| - addField |
| - addFields |
| - addFloatField |
| - addInt16Field |
| - addInt32Field |
| - addInt64Field |
| - addIterableField |
| - addLogicalTypeField |
| - addMapField |
| - addNullableField |
| - addOptions |
| - addRowField |
| - addStringField |
| - array |
| - assignableTo |
| - assignableToIgnoreNullable |
| - build |
| - builder |
| - equals |
| - equivalent |
| - forTypeName |
| - getAllMetadata |
| - getCollectionElementType |
| - getDescription |
| - getEncodingPositions |
| - getField |
| - getFieldCount |
| - getFieldNames |
| - getFields |
| - getLastFieldId |
| - getLogicalType |
| - getMapKeyType |
| - getMapValueType |
| - getMetadata |
| - getMetadataString |
| - getName |
| - getNullable |
| - getOptionNames |
| - getOptions |
| - getRowSchema |
| - getType |
| - getTypeName |
| - getUUID |
| - getValue |
| - getValueOrDefault |
| - hasField |
| - hasOption |
| - hasOptions |
| - hashCode |
| - indexOf |
| - isCollectionType |
| - isCompositeType |
| - isDateType |
| - isEncodingPositionsOverridden |
| - isLogicalType |
| - isMapType |
| - isNumericType |
| - isPrimitiveType |
| - isStringType |
| - isSubtypeOf |
| - isSupertypeOf |
| - iterable |
| - logicalType |
| - map |
| - nameOf |
| - none |
| - nullable |
| - of |
| - row |
| - setDescription |
| - setEncodingPositions |
| - setName |
| - setOption |
| - setOptions |
| - setType |
| - setUUID |
| - sorted |
| - toBuilder |
| - toSchema |
| - toString |
| - typesEqual |
| - withDescription |
| - withMetadata |
| - withName |
| - withNullable |
| - withOptions |
| - withType |
| properties: |
| - BOOLEAN |
| - BYTE |
| - BYTES |
| - COLLECTION_TYPES |
| - COMPOSITE_TYPES |
| - DATETIME |
| - DATE_TYPES |
| - DECIMAL |
| - DOUBLE |
| - FLOAT |
| - INT16 |
| - INT32 |
| - INT64 |
| - MAP_TYPES |
| - NUMERIC_TYPES |
| - STRING |
| - STRING_TYPES |
| SchemaAndRecord: |
| methods: |
| - getRecord |
| - getTableSchema |
| SchemaBaseBeamTable: |
| methods: |
| - getSchema |
| SchemaCoder: |
| methods: |
| - coderForFieldType |
| - consistentWithEquals |
| - decode |
| - encode |
| - equals |
| - getEncodedTypeDescriptor |
| - getFromRowFunction |
| - getSchema |
| - getToRowFunction |
| - hashCode |
| - of |
| - overrideEncodingPositions |
| - toString |
| - verifyDeterministic |
| SchemaIOTableProviderWrapper: |
| methods: |
| - buildBeamSqlTable |
| - buildIOReader |
| - buildIOWriter |
| - getSchema |
| - getSchemaIOProvider |
| - getTableStatistics |
| - getTableType |
| - isBounded |
| - supportsProjects |
| SchemaLogicalType: |
| methods: |
| - getArgumentType |
| - getBaseType |
| - getIdentifier |
| - toBaseType |
| - toInputType |
| properties: |
| - IDENTIFIER |
| SchemaRegistry: |
| methods: |
| - createDefault |
| - fromRowFunction |
| - getFromRowFunction |
| - getSchema |
| - getSchemaCoder |
| - getToRowFunction |
| - registerJavaBean |
| - registerPOJO |
| - registerSchemaForClass |
| - registerSchemaForType |
| - registerSchemaProvider |
| - schemaFor |
| - toRowFunction |
| SchemaTranslation: |
| methods: |
| - rowFromProto |
| - rowToProto |
| - schemaFromProto |
| - schemaToProto |
| SchemaUtils: |
| methods: |
| - mergeWideningNullable |
| - toLogicalBaseType |
| - toLogicalInputType |
| SchemaVerification: |
| methods: |
| - verifyFieldValue |
| SchemaZipFold: |
| methods: |
| - accept |
| - accumulate |
| - apply |
| - create |
| - parent |
| - path |
| - withParent |
| - withPathPart |
| properties: |
| - EMPTY |
| Select: |
| methods: |
| - concatFieldNames |
| - create |
| - expand |
| - fieldAccess |
| - fieldIds |
| - fieldNames |
| - flattenedSchema |
| - keepMostNestedFieldName |
| - process |
| - withFieldNameAs |
| - withOutputSchema |
| SelectEvent: |
| methods: |
| - expand |
| - processElement |
| SelectHelpers: |
| methods: |
| - allLeavesDescriptor |
| - getOutputSchema |
| - getRowSelector |
| - getRowSelectorOptimized |
| - select |
| properties: |
| - CONCAT_FIELD_NAMES |
| - KEEP_NESTED_NAME |
| SellerPrice: |
| methods: |
| - decode |
| - encode |
| - equals |
| - hashCode |
| - sizeInBytes |
| - structuralValue |
| - toString |
| - verifyDeterministic |
| properties: |
| - CODER |
| - seller |
| SerializableCoder: |
| methods: |
| - coderFor |
| - consistentWithEquals |
| - decode |
| - encode |
| - equals |
| - getCoderProvider |
| - getCoderProviders |
| - getEncodedTypeDescriptor |
| - getRecordType |
| - hashCode |
| - of |
| - structuralValue |
| - toString |
| - verifyDeterministic |
| SerializableConfiguration: |
| methods: |
| - fromMap |
| - get |
| - newConfiguration |
| - newJob |
| - readExternal |
| - writeExternal |
| SerializableFunctions: |
| methods: |
| - apply |
| - clonesOf |
| - constant |
| - identity |
| SerializableIr: |
| methods: |
| - fromIr |
| - ir |
| SerializableMatchers: |
| methods: |
| - allOf |
| - anyOf |
| - anything |
| - arrayContaining |
| - arrayContainingInAnyOrder |
| - arrayWithSize |
| - closeTo |
| - contains |
| - containsInAnyOrder |
| - containsString |
| - describeMismatch |
| - describeTo |
| - empty |
| - emptyArray |
| - emptyIterable |
| - endsWith |
| - equalTo |
| - fromSupplier |
| - get |
| - greaterThan |
| - greaterThanOrEqualTo |
| - hasItem |
| - hasSize |
| - isIn |
| - isOneOf |
| - iterableWithSize |
| - kv |
| - kvWithKey |
| - kvWithValue |
| - lessThan |
| - lessThanOrEqualTo |
| - matches |
| - not |
| - nullValue |
| - startsWith |
| - toString |
| SerializableRexFieldAccess: |
| methods: |
| - getIndexes |
| SerializableRexInputRef: |
| methods: |
| - getIndex |
| SerializableRexNode: |
| methods: |
| - build |
| - builder |
| SerializableThrowable: |
| methods: |
| - equals |
| - getThrowable |
| - hashCode |
| SerializableUtils: |
| methods: |
| - clone |
| - deserializeFromByteArray |
| - ensureSerializable |
| - ensureSerializableByCoder |
| - ensureSerializableRoundTrip |
| - serializeToByteArray |
| ServerFactory: |
| methods: |
| - allocateAddressAndCreate |
| - create |
| - createDefault |
| - createEpollDomainSocket |
| - createEpollSocket |
| - createWithPortSupplier |
| - createWithUrlFactory |
| - createWithUrlFactoryAndPortSupplier |
| SessionSideInputJoin: |
| methods: |
| - expand |
| - needsSideInput |
| - processElement |
| SessionSideInputJoinModel: |
| methods: |
| - simulator |
| Sessions: |
| methods: |
| - assignWindows |
| - equals |
| - getDefaultWindowMappingFn |
| - getGapDuration |
| - getWindowTypeDescriptor |
| - hashCode |
| - isCompatible |
| - mergeWindows |
| - populateDisplayData |
| - verifyCompatibility |
| - windowCoder |
| - withGapDuration |
| SetCoder: |
| methods: |
| - getEncodedTypeDescriptor |
| - of |
| - verifyDeterministic |
| Sets: |
| methods: |
| - apply |
| - exceptAll |
| - exceptDistinct |
| - expand |
| - intersectAll |
| - intersectDistinct |
| - processElement |
| - unionAll |
| - unionDistinct |
| ShardNameTemplate: |
| properties: |
| - DIRECTORY_CONTAINER |
| - INDEX_OF_MAX |
| ShardedKey: |
| methods: |
| - consistentWithEquals |
| - decode |
| - encode |
| - equals |
| - getCoderArguments |
| - getKey |
| - getKeyCoder |
| - getShardNumber |
| - hashCode |
| - isRegisterByteSizeObserverCheap |
| - of |
| - registerByteSizeObserver |
| - structuralValue |
| - toString |
| - verifyDeterministic |
| ShardedKeyCoder: |
| methods: |
| - decode |
| - encode |
| - getCoderArguments |
| - of |
| - verifyDeterministic |
| ShardingWritableByteChannel: |
| methods: |
| - addChannel |
| - close |
| - getChannel |
| - getNumShards |
| - isOpen |
| - write |
| - writeToShard |
| properties: |
| - ALL_SHARDS |
| ShuffleOperator: |
| methods: |
| - getKeyExtractor |
| - getKeyType |
| - getWindow |
| SideInputLoadTest: |
| methods: |
| - main |
| - processElement |
| SideInputSpec: |
| methods: |
| - create |
| SimpleFunction: |
| methods: |
| - apply |
| - fromSerializableFunctionWithOutputType |
| - getOutputTypeDescriptor |
| SingleStoreIO: |
| methods: |
| - create |
| - expand |
| - finish |
| - getDataSource |
| - getInitialRange |
| - populateDisplayData |
| - process |
| - processElement |
| - read |
| - readRows |
| - readWithPartitions |
| - readWithPartitionsRows |
| - run |
| - splitRange |
| - withBatchSize |
| - withConnectionProperties |
| - withDataSourceConfiguration |
| - withDatabase |
| - withOutputParallelization |
| - withPassword |
| - withQuery |
| - withRowMapper |
| - withStatementPreparator |
| - withTable |
| - withUserDataMapper |
| - withUsername |
| - write |
| - writeRows |
| SingleStoreSchemaTransformReadConfiguration: |
| methods: |
| - build |
| - builder |
| - getDataSourceConfiguration |
| - getOutputParallelization |
| - getQuery |
| - getTable |
| - getWithPartitions |
| - setDataSourceConfiguration |
| - setOutputParallelization |
| - setQuery |
| - setTable |
| - setWithPartitions |
| - toBeamRow |
| SingleStoreSchemaTransformReadProvider: |
| methods: |
| - buildTransform |
| - expand |
| - identifier |
| - inputCollectionNames |
| - outputCollectionNames |
| SingleStoreSchemaTransformWriteConfiguration: |
| methods: |
| - build |
| - builder |
| - getBatchSize |
| - getDataSourceConfiguration |
| - getTable |
| - setBatchSize |
| - setDataSourceConfiguration |
| - setTable |
| - toBeamRow |
| SingleStoreSchemaTransformWriteProvider: |
| methods: |
| - buildTransform |
| - expand |
| - identifier |
| - inputCollectionNames |
| - outputCollectionNames |
| properties: |
| - INPUT_TAG |
| SingleValueCollector: |
| methods: |
| - asContext |
| - collect |
| - get |
| - getCounter |
| - getHistogram |
| - getTimer |
| SingleValueContext: |
| methods: |
| - asContext |
| - collect |
| - get |
| - getAndResetValue |
| - getCounter |
| - getHistogram |
| - getTimer |
| SinkMetrics: |
| methods: |
| - bytesWritten |
| - elementsWritten |
| SizeEstimator: |
| methods: |
| - sizeOf |
| SketchFrequencies: |
| methods: |
| - add |
| - addInput |
| - create |
| - createAccumulator |
| - decode |
| - encode |
| - estimateCount |
| - expand |
| - extractOutput |
| - getAccumulatorCoder |
| - globally |
| - isRegisterByteSizeObserverCheap |
| - mergeAccumulators |
| - perKey |
| - populateDisplayData |
| - withAccuracy |
| - withConfidence |
| - withRelativeError |
| SlidingWindows: |
| methods: |
| - assignWindows |
| - assignsToOneWindow |
| - equals |
| - every |
| - getDefaultWindowMappingFn |
| - getOffset |
| - getPeriod |
| - getSideInputWindow |
| - getSize |
| - hashCode |
| - isCompatible |
| - of |
| - populateDisplayData |
| - verifyCompatibility |
| - windowCoder |
| - withOffset |
| SnappyCoder: |
| methods: |
| - decode |
| - encode |
| - getCoderArguments |
| - of |
| - verifyDeterministic |
| SnowflakeArray: |
| methods: |
| - of |
| - sql |
| SnowflakeBatchServiceConfig: |
| methods: |
| - getCreateDisposition |
| - getDataSourceProviderFn |
| - getDatabase |
| - getFilesList |
| - getQuery |
| - getQuotationMark |
| - getSchema |
| - getStagingBucketDir |
| - getStorageIntegrationName |
| - getTable |
| - getTableSchema |
| - getWriteDisposition |
| SnowflakeBatchServiceImpl: |
| methods: |
| - read |
| - write |
| SnowflakeBinary: |
| methods: |
| - getSize |
| - of |
| - setSize |
| - sql |
| properties: |
| - MAX_SIZE |
| SnowflakeBoolean: |
| methods: |
| - of |
| - sql |
| SnowflakeChar: |
| methods: |
| - of |
| SnowflakeColumn: |
| methods: |
| - getDataType |
| - getName |
| - isNullable |
| - of |
| - setDataType |
| - setName |
| - setNullable |
| - sql |
| SnowflakeDate: |
| methods: |
| - of |
| - sql |
| SnowflakeDateTime: |
| methods: |
| - of |
| SnowflakeDecimal: |
| methods: |
| - of |
| SnowflakeDouble: |
| methods: |
| - of |
| SnowflakeFloat: |
| methods: |
| - of |
| - sql |
| SnowflakeGeography: |
| methods: |
| - of |
| - sql |
| SnowflakeIO: |
| methods: |
| - addInput |
| - apply |
| - buildDatasource |
| - create |
| - createAccumulator |
| - expand |
| - extractOutput |
| - finishBundle |
| - fromQuery |
| - fromTable |
| - getAuthenticator |
| - getConfig |
| - getDataSource |
| - getDatabase |
| - getLoginTimeout |
| - getOauthToken |
| - getPassword |
| - getPortNumber |
| - getPrivateKey |
| - getPrivateKeyPassphrase |
| - getRawPrivateKey |
| - getRole |
| - getSchema |
| - getServerName |
| - getSsl |
| - getUrl |
| - getUsername |
| - getWarehouse |
| - mergeAccumulators |
| - of |
| - populateDisplayData |
| - processElement |
| - read |
| - setup |
| - to |
| - withAuthenticator |
| - withCoder |
| - withCreateDisposition |
| - withCsvMapper |
| - withDataSourceConfiguration |
| - withDataSourceProviderFn |
| - withDatabase |
| - withDebugMode |
| - withFileNameTemplate |
| - withFlushRowLimit |
| - withFlushTimeLimit |
| - withKeyPairAuth |
| - withKeyPairPathAuth |
| - withKeyPairRawAuth |
| - withLoginTimeout |
| - withOAuth |
| - withPortNumber |
| - withQueryTransformation |
| - withQuotationMark |
| - withRole |
| - withSchema |
| - withServerName |
| - withShardsNumber |
| - withSnowPipe |
| - withSnowflakeServices |
| - withStagingBucketName |
| - withStorageIntegrationName |
| - withTableSchema |
| - withUrl |
| - withUserDataMapper |
| - withUsernamePasswordAuth |
| - withWarehouse |
| - withWriteDisposition |
| - write |
| SnowflakeInteger: |
| methods: |
| - of |
| SnowflakeNumber: |
| methods: |
| - getPrecision |
| - getScale |
| - of |
| - setPrecision |
| - setScale |
| - sql |
| SnowflakeNumeric: |
| methods: |
| - of |
| SnowflakeObject: |
| methods: |
| - of |
| - sql |
| SnowflakeReal: |
| methods: |
| - of |
| SnowflakeServicesImpl: |
| methods: |
| - getBatchService |
| - getStreamingService |
| SnowflakeStreamingServiceConfig: |
| methods: |
| - getFilesList |
| - getIngestManager |
| - getStagingBucketDir |
| SnowflakeStreamingServiceImpl: |
| methods: |
| - read |
| - write |
| SnowflakeString: |
| methods: |
| - of |
| SnowflakeTableSchema: |
| methods: |
| - getColumns |
| - of |
| - setColumns |
| - sql |
| SnowflakeText: |
| methods: |
| - of |
| SnowflakeTime: |
| methods: |
| - of |
| - sql |
| SnowflakeTimestamp: |
| methods: |
| - of |
| SnowflakeTimestampLTZ: |
| methods: |
| - of |
| - sql |
| SnowflakeTimestampNTZ: |
| methods: |
| - of |
| - sql |
| SnowflakeTimestampTZ: |
| methods: |
| - of |
| - sql |
| SnowflakeTransformRegistrar: |
| methods: |
| - knownBuilderInstances |
| properties: |
| - READ_URN |
| - WRITE_URN |
| SnowflakeVarBinary: |
| methods: |
| - of |
| SnowflakeVarchar: |
| methods: |
| - getLength |
| - of |
| - setLength |
| - sql |
| properties: |
| - MAX_LENGTH |
| SnowflakeVariant: |
| methods: |
| - of |
| - sql |
| SnsCoderProviderRegistrar: |
| methods: |
| - getCoderProviders |
| SnsIO: |
| methods: |
| - create |
| - expand |
| - processElement |
| - setup |
| - tearDown |
| - test |
| - withAWSClientsProvider |
| - withClientConfiguration |
| - withCoder |
| - withFullPublishResponse |
| - withFullPublishResponseWithoutHeaders |
| - withFullPublishResult |
| - withFullPublishResultWithoutHeaders |
| - withPublishRequestBuilder |
| - withPublishRequestFn |
| - withResultOutputTag |
| - withRetryConfiguration |
| - withSnsClientProvider |
| - withTopicArn |
| - withTopicName |
| - write |
| - writeAsync |
| SocketAddressFactory: |
| methods: |
| - createFrom |
| SolrIO: |
| methods: |
| - baseUrl |
| - closeClient |
| - coreName |
| - coreUrl |
| - create |
| - expand |
| - finishBundle |
| - from |
| - populateDisplayData |
| - process |
| - processElement |
| - read |
| - readAll |
| - setup |
| - startBundle |
| - test |
| - to |
| - withBasicCredentials |
| - withConnectionConfiguration |
| - withMaxBatchSize |
| - withQuery |
| - withReplicaInfo |
| - withRetryConfiguration |
| - write |
| SortValues: |
| methods: |
| - create |
| - expand |
| - hasNext |
| - iterator |
| - next |
| - processElement |
| - remove |
| SortedMapCoder: |
| methods: |
| - consistentWithEquals |
| - decode |
| - encode |
| - getCoderArguments |
| - getEncodedTypeDescriptor |
| - getKeyCoder |
| - getValueCoder |
| - of |
| - registerByteSizeObserver |
| - structuralValue |
| - verifyDeterministic |
| Source: |
| methods: |
| - advance |
| - close |
| - getCurrent |
| - getCurrentSource |
| - getCurrentTimestamp |
| - getDefaultOutputCoder |
| - getOutputCoder |
| - populateDisplayData |
| - start |
| - validate |
| SourceMetrics: |
| methods: |
| - backlogBytes |
| - backlogBytesOfSplit |
| - backlogElements |
| - backlogElementsOfSplit |
| - bytesRead |
| - bytesReadBySplit |
| - elementsRead |
| - elementsReadBySplit |
| SourceRecordJson: |
| methods: |
| - mapSourceRecord |
| - toJson |
| SourceTestUtils: |
| methods: |
| - advance |
| - assertSourcesEqualReferenceSource |
| - assertSplitAtFractionBehavior |
| - assertSplitAtFractionExhaustive |
| - assertSplitAtFractionFails |
| - assertSplitAtFractionSucceedsAndConsistent |
| - assertUnstartedReaderReadsSameAsItsSource |
| - close |
| - createReader |
| - createStructuralValues |
| - equals |
| - getCurrent |
| - getCurrentSource |
| - getCurrentTimestamp |
| - getEstimatedSizeBytes |
| - getFractionConsumed |
| - getOutputCoder |
| - getSplitPointsConsumed |
| - getSplitPointsRemaining |
| - hashCode |
| - populateDisplayData |
| - readFromSource |
| - readFromSplitsOfSource |
| - readFromStartedReader |
| - readFromUnstartedReader |
| - readNItemsFromStartedReader |
| - readNItemsFromUnstartedReader |
| - readRemainingFromReader |
| - split |
| - splitAtFraction |
| - start |
| - toString |
| - toUnsplittableSource |
| - validate |
| properties: |
| - numPrimaryItems |
| - numResidualItems |
| SpannerAccessor: |
| methods: |
| - close |
| - getBatchClient |
| - getDatabaseAdminClient |
| - getDatabaseClient |
| - getOrCreate |
| SpannerConfig: |
| methods: |
| - build |
| - create |
| - getCommitDeadline |
| - getCommitRetrySettings |
| - getDatabaseId |
| - getDatabaseRole |
| - getEmulatorHost |
| - getExecuteStreamingSqlRetrySettings |
| - getHost |
| - getInstanceId |
| - getIsLocalChannelProvider |
| - getMaxCumulativeBackoff |
| - getProjectId |
| - getRetryableCodes |
| - getRpcPriority |
| - populateDisplayData |
| - validate |
| - withCommitDeadline |
| - withCommitRetrySettings |
| - withDatabaseId |
| - withDatabaseRole |
| - withEmulatorHost |
| - withExecuteStreamingSqlRetrySettings |
| - withHost |
| - withInstanceId |
| - withIsLocalChannelProvider |
| - withMaxCumulativeBackoff |
| - withProjectId |
| - withRetryableCodes |
| - withRpcPriority |
| SpannerIO: |
| methods: |
| - build |
| - compareTo |
| - createTransaction |
| - expand |
| - finishBundle |
| - grouped |
| - load |
| - of |
| - output |
| - outputWithTimestamp |
| - populateDisplayData |
| - processElement |
| - read |
| - readAll |
| - readChangeStream |
| - setSpannerConfig |
| - setTimestampBound |
| - setup |
| - teardown |
| - withBatchSizeBytes |
| - withBatching |
| - withChangeStreamName |
| - withColumns |
| - withCommitDeadline |
| - withDatabaseId |
| - withDialectView |
| - withEmulatorHost |
| - withFailureMode |
| - withGroupingFactor |
| - withHighPriority |
| - withHost |
| - withInclusiveEndAt |
| - withInclusiveStartAt |
| - withIndex |
| - withInstanceId |
| - withKeySet |
| - withLowPriority |
| - withMaxCumulativeBackoff |
| - withMaxNumMutations |
| - withMaxNumRows |
| - withMetadataDatabase |
| - withMetadataInstance |
| - withMetadataTable |
| - withPartitionOptions |
| - withProjectId |
| - withQuery |
| - withQueryName |
| - withReadOperation |
| - withRpcPriority |
| - withSchemaReadySignal |
| - withSpannerConfig |
| - withTable |
| - withTimestamp |
| - withTimestampBound |
| - withTraceSampleProbability |
| - withTransaction |
| - write |
| SpannerTransformRegistrar: |
| methods: |
| - buildExternal |
| - getReadOperation |
| - knownBuilderInstances |
| - setBatching |
| - setCommitDeadline |
| - setDatabaseId |
| - setEmulatorHost |
| - setGroupingFactor |
| - setHost |
| - setInstanceId |
| - setMaxBatchSizeBytes |
| - setMaxCumulativeBackoff |
| - setMaxNumberMutations |
| - setMaxNumberRows |
| - setProjectId |
| - setReadTimestamp |
| - setSchema |
| - setSql |
| - setStaleness |
| - setTable |
| - setTimeUnit |
| - setTimestampBoundMode |
| properties: |
| - DELETE_URN |
| - INSERT_OR_UPDATE_URN |
| - INSERT_URN |
| - READ_URN |
| - REPLACE_URN |
| - UPDATE_URN |
| SpannerWriteResult: |
| methods: |
| - expand |
| - finishSpecifyingOutput |
| - getFailedMutations |
| - getOutput |
| - getPipeline |
| SpannerWriteSchemaTransformProvider: |
| methods: |
| - build |
| - buildTransform |
| - builder |
| - expand |
| - getDatabaseId |
| - getInstanceId |
| - getTableId |
| - identifier |
| - inputCollectionNames |
| - outputCollectionNames |
| - setDatabaseId |
| - setInstanceId |
| - setTableId |
| SparkReceiverIO: |
| methods: |
| - expand |
| - read |
| - validateTransform |
| - withGetOffsetFn |
| - withPullFrequencySec |
| - withSparkReceiverBuilder |
| - withStartOffset |
| - withTimestampFn |
| Split: |
| methods: |
| - named |
| - negative |
| - of |
| - output |
| - positive |
| - using |
| SplitResult: |
| methods: |
| - getPrimary |
| - getResidual |
| - of |
| SplunkEvent: |
| methods: |
| - create |
| - event |
| - host |
| - index |
| - newBuilder |
| - source |
| - sourceType |
| - time |
| - withEvent |
| - withHost |
| - withIndex |
| - withSource |
| - withSourceType |
| - withTime |
| SplunkIO: |
| methods: |
| - expand |
| - processElement |
| - setup |
| - withBatchCount |
| - withDisableCertificateValidation |
| - withEnableBatchLogs |
| - withEnableGzipHttpCompression |
| - withParallelism |
| - withRootCaCertificatePath |
| - write |
| SplunkWriteError: |
| methods: |
| - create |
| - newBuilder |
| - payload |
| - statusCode |
| - statusMessage |
| - withPayload |
| - withStatusCode |
| - withStatusMessage |
| SqlAnalyzer: {} |
| SqlBoundedSideInputJoin: |
| methods: |
| - calciteSqlBoundedSideInputJoin |
| - expand |
| - needsSideInput |
| - zetaSqlBoundedSideInputJoin |
| SqlCheckConstraint: |
| methods: |
| - getOperandList |
| - getOperator |
| - unparse |
| SqlColumnDeclaration: |
| methods: |
| - getOperandList |
| - getOperator |
| - unparse |
| SqlConversionException: {} |
| SqlCreateExternalTable: |
| methods: |
| - execute |
| - getOperandList |
| - unparse |
| SqlCreateFunction: |
| methods: |
| - execute |
| - getOperandList |
| - getOperator |
| - unparse |
| SqlDdlNodes: |
| methods: |
| - column |
| - dropTable |
| SqlDropTable: {} |
| SqlOperators: |
| methods: |
| - createStringAggOperator |
| - createZetaSqlFunction |
| - getSyntax |
| properties: |
| - ARRAY_AGG_FN |
| - BIT_XOR |
| - CAST_OP |
| - CHAR_LENGTH |
| - CONCAT |
| - COUNTIF |
| - DATE_OP |
| - ENDS_WITH |
| - LIKE |
| - LTRIM |
| - REPLACE |
| - REVERSE |
| - RTRIM |
| - START_WITHS |
| - SUBSTR |
| - TIMESTAMP_OP |
| - TRIM |
| - VALIDATE_TIMESTAMP |
| - VALIDATE_TIME_INTERVAL |
| - ZETASQL_TIMESTAMP_ADD |
| SqlQuery0: |
| methods: |
| - calciteSqlQuery0 |
| - expand |
| - processElement |
| - zetaSqlQuery0 |
| SqlQuery1: |
| methods: |
| - apply |
| - expand |
| SqlQuery2: |
| methods: |
| - calciteSqlQuery2 |
| - expand |
| - zetaSqlQuery2 |
| SqlQuery3: |
| methods: |
| - calciteSqlQuery3 |
| - expand |
| - zetaSqlQuery3 |
| SqlQuery5: |
| methods: |
| - expand |
| SqlQuery7: |
| methods: |
| - expand |
| SqlSetOptionBeam: |
| methods: |
| - execute |
| SqlTransform: |
| methods: |
| - expand |
| - query |
| - registerUdaf |
| - registerUdf |
| - withAutoLoading |
| - withDdlString |
| - withDefaultTableProvider |
| - withErrorsTransformer |
| - withNamedParameters |
| - withPositionalParameters |
| - withQueryPlannerClass |
| - withTableProvider |
| SqlTransformRunner: |
| methods: |
| - getIdentifiers |
| - runUsingSqlTransform |
| - visit |
| SqlTypes: |
| properties: |
| - DATE |
| - DATETIME |
| - TIME |
| - TIMESTAMP |
| SqsIO: |
| methods: |
| - expand |
| - processElement |
| - read |
| - setup |
| - teardown |
| - withClientConfiguration |
| - withCoder |
| - withMaxNumRecords |
| - withMaxReadTime |
| - withQueueUrl |
| - withSqsClientProvider |
| - write |
| SqsMessage: |
| methods: |
| - create |
| - getBody |
| - getMessageId |
| - getReceiptHandle |
| - getRequestTimeStamp |
| - getTimeStamp |
| StateBackedIterable: |
| methods: |
| - encode |
| - fromComponents |
| - getCoderTranslators |
| - getCoderURNs |
| - getComponents |
| - iterator |
| StateContexts: |
| methods: |
| - getPipelineOptions |
| - nullContext |
| - sideInput |
| - window |
| - windowOnlyContext |
| StateFetchingIterators: |
| methods: |
| - append |
| - clearAndAppend |
| - createIterator |
| - fromValues |
| - getBlocks |
| - getContinuationToken |
| - getWeight |
| - hasNext |
| - isReady |
| - loadPrefetchedResponse |
| - mutatedBlock |
| - next |
| - prefetch |
| - readAllAndDecodeStartingFrom |
| - remove |
| - seekToContinuationToken |
| - shrink |
| StateKeySpec: |
| methods: |
| - fields |
| StateSpecs: |
| methods: |
| - bag |
| - bind |
| - combining |
| - combiningFromInputInternal |
| - convertToBagSpecInternal |
| - convertToMapSpecInternal |
| - equals |
| - finishSpecifying |
| - hashCode |
| - map |
| - match |
| - multimap |
| - offerCoders |
| - orderedList |
| - rowBag |
| - rowMap |
| - rowMultimap |
| - rowOrderedList |
| - rowSet |
| - rowValue |
| - set |
| - value |
| - watermarkStateInternal |
| StaticSchemaInference: |
| methods: |
| - fieldFromType |
| - schemaFromClass |
| - sortBySchema |
| StorageApiConvertMessages: |
| methods: |
| - expand |
| - onTeardown |
| - processElement |
| StorageApiDynamicDestinationsTableRow: |
| methods: |
| - getMessageConverter |
| - getTableSchema |
| - toMessage |
| - toTableRow |
| StorageApiFlushAndFinalizeDoFn: |
| methods: |
| - compareTo |
| - equals |
| - hashCode |
| - onTeardown |
| - process |
| StorageApiLoads: |
| methods: |
| - expand |
| - expandInconsistent |
| - expandTriggered |
| - expandUntriggered |
| - processElement |
| - setup |
| StorageApiWritePayload: |
| methods: |
| - getPayload |
| StorageApiWriteRecordsInconsistent: |
| methods: |
| - expand |
| StorageApiWriteUnshardedRecords: |
| methods: |
| - expand |
| - finishBundle |
| - output |
| - outputWithTimestamp |
| - process |
| - startBundle |
| - teardown |
| StorageApiWritesShardedRecords: |
| methods: |
| - expand |
| - getAllowedTimestampSkew |
| - onTeardown |
| - onTimer |
| - onWindowExpiration |
| - process |
| - startBundle |
| - toString |
| StreamUtils: |
| methods: |
| - getBytesWithoutClosing |
| StreamingInserts: |
| methods: |
| - expand |
| - withExtendedErrorInfo |
| - withInsertRetryPolicy |
| StreamingSourceContextImpl: |
| methods: |
| - isPreviewEnabled |
| - registerLineage |
| StreamingWriteTables: |
| methods: |
| - apply |
| - expand |
| StringAgg: |
| methods: |
| - addInput |
| - createAccumulator |
| - extractOutput |
| - mergeAccumulators |
| StringDelegateCoder: |
| methods: |
| - decode |
| - encode |
| - equals |
| - getEncodedTypeDescriptor |
| - hashCode |
| - of |
| - structuralValue |
| - toString |
| - verifyDeterministic |
| StringFunctions: |
| methods: |
| - charLength |
| - concat |
| - endsWith |
| - like |
| - ltrim |
| - replace |
| - reverse |
| - rtrim |
| - startsWith |
| - substr |
| - trim |
| properties: |
| - SUBSTR_PARAMETER_EXCEED_INTEGER |
| StringUtf8Coder: |
| methods: |
| - consistentWithEquals |
| - decode |
| - encode |
| - getEncodedElementByteSize |
| - getEncodedTypeDescriptor |
| - of |
| - verifyDeterministic |
| StringUtils: |
| methods: |
| - byteArrayToJsonString |
| - getLevenshteinDistance |
| - jsonStringToByteArray |
| StringsGenerator: |
| methods: |
| - nextExactString |
| - nextExtra |
| - nextString |
| StructuralByteArray: |
| methods: |
| - equals |
| - getValue |
| - hashCode |
| - toString |
| StructuredCoder: |
| methods: |
| - equals |
| - getComponents |
| - hashCode |
| - toString |
| SubscribeTransform: |
| methods: |
| - expand |
| - getReplacementTransform |
| - mapOutputs |
| properties: |
| - V1_READ_OVERRIDE |
| SubscriberOptions: |
| methods: |
| - build |
| - newBuilder |
| - setSubscriptionPath |
| - subscriptionPath |
| - toBuilder |
| SubscriptionPartition: {} |
| SubscriptionPartitionCoder: |
| methods: |
| - decode |
| - encode |
| - getCoderProvider |
| SuccessOrFailure: |
| methods: |
| - assertionError |
| - equals |
| - failure |
| - hashCode |
| - isSuccess |
| - success |
| - toString |
| Sum: |
| methods: |
| - apply |
| - doublesGlobally |
| - doublesPerKey |
| - equals |
| - hashCode |
| - identity |
| - integersGlobally |
| - integersPerKey |
| - longsGlobally |
| - longsPerKey |
| - ofDoubles |
| - ofIntegers |
| - ofLongs |
| SumByKey: |
| methods: |
| - accumulationMode |
| - expand |
| - getValueExtractor |
| - keyBy |
| - named |
| - of |
| - output |
| - triggeredBy |
| - valueBy |
| - windowBy |
| - withAllowedLateness |
| - withOnTimeBehavior |
| - withTimestampCombiner |
| SummaryGenerator: |
| methods: |
| - generateTable |
| Sums: |
| methods: |
| - apply |
| - identity |
| - ofDoubles |
| - ofFloats |
| - ofInts |
| - ofLongs |
| - valueDesc |
| SynchronizedStreamObserver: |
| methods: |
| - onCompleted |
| - onError |
| - onNext |
| - wrapping |
| SyntheticBoundedSource: |
| methods: |
| - allowsDynamicSplitting |
| - close |
| - createReader |
| - createSourceForSubrange |
| - getBytesPerOffset |
| - getCurrent |
| - getCurrentSource |
| - getDefaultOutputCoder |
| - getFractionConsumed |
| - getMaxEndOffset |
| - split |
| - toString |
| - validate |
| SyntheticDataPublisher: |
| methods: |
| - apply |
| - main |
| SyntheticDelay: |
| methods: |
| - delay |
| SyntheticOptions: |
| methods: |
| - deserialize |
| - fromIntegerDistribution |
| - fromJsonString |
| - fromRealDistribution |
| - genKvPair |
| - getDistribution |
| - hashFunction |
| - nextDelay |
| - sample |
| - setSeed |
| - toString |
| - validate |
| properties: |
| - bytesPerRecord |
| - cpuUtilizationInMixedDelay |
| - delayType |
| - hotKeyFraction |
| - keySizeBytes |
| - largeKeyFraction |
| - largeKeySizeBytes |
| - numHotKeys |
| - seed |
| - valueSizeBytes |
| SyntheticSourceOptions: |
| methods: |
| - genRecord |
| - nextInitializeDelay |
| - nextProcessingTimeDelay |
| - validate |
| properties: |
| - bundleSizeDistribution |
| - forceNumInitialBundles |
| - kv |
| - numRecords |
| - progressShape |
| - sleepMsec |
| - splitPointFrequencyRecords |
| - watermarkDriftMillis |
| - watermarkSearchInAdvanceCount |
| SyntheticStep: |
| methods: |
| - load |
| - processElement |
| - startBundle |
| - validate |
| properties: |
| - maxWorkerThroughput |
| - outputRecordsPerInputRecord |
| - perBundleDelay |
| - perBundleDelayType |
| - preservesInputKeyDistribution |
| - reportThrottlingMicros |
| SyntheticUnboundedSource: |
| methods: |
| - advance |
| - close |
| - createReader |
| - getCheckpointMark |
| - getCheckpointMarkCoder |
| - getCurrent |
| - getCurrentSource |
| - getCurrentTimestamp |
| - getOutputCoder |
| - getWatermark |
| - split |
| - start |
| - toString |
| - validate |
| TDigestQuantiles: |
| methods: |
| - addInput |
| - create |
| - createAccumulator |
| - decode |
| - encode |
| - expand |
| - extractOutput |
| - getAccumulatorCoder |
| - getDefaultOutputCoder |
| - globally |
| - isRegisterByteSizeObserverCheap |
| - mergeAccumulators |
| - perKey |
| - populateDisplayData |
| - withCompression |
| TFRecordIO: |
| methods: |
| - allowsDynamicSplitting |
| - apply |
| - createWriteOperation |
| - createWriter |
| - expand |
| - flush |
| - from |
| - getCurrent |
| - getOutputCoder |
| - matches |
| - open |
| - populateDisplayData |
| - read |
| - readFiles |
| - recordLength |
| - sink |
| - to |
| - toResource |
| - withCompression |
| - withCompressionType |
| - withNoSpilling |
| - withNumShards |
| - withShardNameTemplate |
| - withSuffix |
| - withoutSharding |
| - withoutValidation |
| - write |
| properties: |
| - DEFAULT_BYTE_ARRAY_CODER |
| TVFSlidingWindowFn: |
| methods: |
| - assignWindows |
| - getDefaultWindowMappingFn |
| - getPeriod |
| - getSize |
| - isCompatible |
| - of |
| - windowCoder |
| TVFStreamingUtils: |
| properties: |
| - FIXED_WINDOW_TVF |
| - SESSION_WINDOW_TVF |
| - SLIDING_WINDOW_TVF |
| - WINDOW_END |
| - WINDOW_START |
| Table: |
| methods: |
| - build |
| - builder |
| - comment |
| - getComment |
| - getLocation |
| - getName |
| - getProperties |
| - getSchema |
| - getType |
| - location |
| - name |
| - properties |
| - schema |
| - toBuilder |
| - type |
| TableAndRecord: |
| methods: |
| - getRecord |
| - getTable |
| TableDestination: |
| methods: |
| - equals |
| - getClustering |
| - getJsonClustering |
| - getJsonTimePartitioning |
| - getTableDescription |
| - getTableReference |
| - getTableSpec |
| - getTableUrn |
| - getTimePartitioning |
| - hashCode |
| - toString |
| - withTableReference |
| TableDestinationCoder: |
| methods: |
| - decode |
| - encode |
| - of |
| - verifyDeterministic |
| TableDestinationCoderV2: |
| methods: |
| - decode |
| - encode |
| - of |
| - verifyDeterministic |
| TableDestinationCoderV3: |
| methods: |
| - decode |
| - encode |
| - of |
| - verifyDeterministic |
| TableName: |
| methods: |
| - create |
| - getPath |
| - getPrefix |
| - getTableName |
| - isCompound |
| - isSimple |
| - removePrefix |
| TableNameExtractionUtils: |
| methods: |
| - extractTableNamesFromNode |
| TableResolution: |
| methods: |
| - registerTables |
| - resolveCalciteTable |
| TableRowJsonCoder: |
| methods: |
| - decode |
| - encode |
| - getEncodedElementByteSize |
| - getEncodedTypeDescriptor |
| - of |
| - verifyDeterministic |
| TableRowToStorageApiProto: |
| methods: |
| - getDescriptorFromTableSchema |
| - getFullName |
| - getName |
| - getSchemaForField |
| - getType |
| - jsonValueFromMessageValue |
| - messageFromMap |
| - messageFromTableRow |
| - modeToProtoMode |
| - protoModeToJsonMode |
| - protoSchemaToTableSchema |
| - protoTableFieldToTableField |
| - protoTypeToJsonType |
| - schemaToProtoTableSchema |
| - tableFieldToProtoTableField |
| - tableRowFromMessage |
| - typeToProtoType |
| TableSchema: |
| methods: |
| - array |
| - arrayElementType |
| - build |
| - builder |
| - columnType |
| - columns |
| - defaultType |
| - defaultValue |
| - enum16 |
| - enum8 |
| - enumValues |
| - fixedString |
| - fixedStringSize |
| - getEquivalentFieldType |
| - getEquivalentSchema |
| - materializedOrAlias |
| - name |
| - nullable |
| - of |
| - parse |
| - parseDefaultExpression |
| - typeName |
| - withNullable |
| properties: |
| - DATE |
| - DATETIME |
| - FLOAT32 |
| - FLOAT64 |
| - INT16 |
| - INT32 |
| - INT64 |
| - INT8 |
| - STRING |
| - UINT16 |
| - UINT32 |
| - UINT64 |
| - UINT8 |
| TableSchemaCache: |
| methods: |
| - getSchema |
| - isSatisfied |
| - putSchemaIfAbsent |
| - refreshSchema |
| - refreshThread |
| TableSchemaJSONLoader: |
| methods: |
| - getAllTableNames |
| - parseTableSchema |
| TaggedPValue: |
| methods: |
| - getTag |
| - getValue |
| - of |
| - ofExpandedValue |
| TestBigQuery: |
| methods: |
| - apply |
| - assertThatAllRows |
| - create |
| - evaluate |
| - eventually |
| - getFlatJsonRows |
| - insertRows |
| - now |
| - tableReference |
| - tableSpec |
| TestPipeline: |
| methods: |
| - apply |
| - create |
| - enableAbandonedNodeEnforcement |
| - enableAutoRunIfMissing |
| - evaluate |
| - fromOptions |
| - getOptions |
| - isEmpty |
| - leaveCompositeTransform |
| - newProvider |
| - run |
| - runWithAdditionalOptionArgs |
| - testingPipelineOptions |
| - toString |
| - verifyPAssertsSucceeded |
| - visitPrimitiveTransform |
| properties: |
| - PROPERTY_BEAM_TEST_PIPELINE_OPTIONS |
| TestPubsub: |
| methods: |
| - apply |
| - assertSubscriptionEventuallyCreated |
| - assertThatTopicEventuallyReceives |
| - checkIfAnySubscriptionExists |
| - create |
| - evaluate |
| - fromOptions |
| - publish |
| - subscriptionPath |
| - topicPath |
| - waitForNMessages |
| TestPubsubSignal: |
| methods: |
| - apply |
| - create |
| - evaluate |
| - expand |
| - processElement |
| - signalStart |
| - signalSuccessWhen |
| - waitForStart |
| - waitForSuccess |
| TestStream: |
| methods: |
| - add |
| - addElements |
| - advanceBy |
| - advanceProcessingTime |
| - advanceTo |
| - advanceWatermarkTo |
| - advanceWatermarkToInfinity |
| - create |
| - decode |
| - encode |
| - equals |
| - expand |
| - fromRawEvents |
| - getCoderArguments |
| - getElements |
| - getEvents |
| - getProcessingTimeAdvance |
| - getValueCoder |
| - getWatermark |
| - hashCode |
| - of |
| - verifyDeterministic |
| TextIO: |
| methods: |
| - apply |
| - expand |
| - flush |
| - from |
| - matches |
| - open |
| - populateDisplayData |
| - read |
| - readAll |
| - readFiles |
| - sink |
| - skipIfEmpty |
| - to |
| - toResource |
| - watchForNewFiles |
| - withCompression |
| - withCompressionType |
| - withDelimiter |
| - withEmptyMatchTreatment |
| - withFooter |
| - withFormatFunction |
| - withHeader |
| - withHintMatchesManyFiles |
| - withMatchConfiguration |
| - withNoSpilling |
| - withNumShards |
| - withOutputFilenames |
| - withShardNameTemplate |
| - withSuffix |
| - withTempDirectory |
| - withWindowedWrites |
| - withWritableByteChannelFactory |
| - withoutSharding |
| - write |
| - writeCustomType |
| TextJsonTable: {} |
| TextMessageMapper: |
| methods: |
| - apply |
| TextRowCountEstimator: |
| methods: |
| - build |
| - builder |
| - estimateRowCount |
| - getCompression |
| - getDelimiters |
| - getDirectoryTreatment |
| - getEmptyMatchTreatment |
| - getFilePattern |
| - getNumSampledBytesPerFile |
| - getSamplingStrategy |
| - setCompression |
| - setDelimiters |
| - setDirectoryTreatment |
| - setEmptyMatchTreatment |
| - setFilePattern |
| - setNumSampledBytesPerFile |
| - setSamplingStrategy |
| - stopSampling |
| TextSourceBenchmark: |
| methods: |
| - benchmarkHadoopLineReader |
| - benchmarkTextSource |
| - createFile |
| - deleteFile |
| properties: |
| - length |
| - path |
| - pathString |
| TextTable: |
| methods: |
| - buildIOReader |
| - buildIOWriter |
| - getFilePattern |
| - getTableStatistics |
| - isBounded |
| TextTableProvider: |
| methods: |
| - buildBeamSqlTable |
| - create |
| - deadLetterFile |
| - expand |
| - getCsvFormat |
| - getTableType |
| - processElement |
| - schema |
| TextualIntegerCoder: |
| methods: |
| - decode |
| - encode |
| - getEncodedTypeDescriptor |
| - of |
| - verifyDeterministic |
| ThriftCoder: |
| methods: |
| - decode |
| - encode |
| - of |
| ThriftIO: |
| methods: |
| - build |
| - close |
| - expand |
| - flush |
| - open |
| - populateDisplayData |
| - processElement |
| - readFiles |
| - sink |
| - withProtocol |
| - write |
| ThriftPayloadSerializerProvider: |
| methods: |
| - getSerializer |
| - identifier |
| ThriftSchema: |
| methods: |
| - custom |
| - fieldValueGetters |
| - fieldValueTypeInformations |
| - get |
| - name |
| - provider |
| - schemaFor |
| - schemaTypeCreator |
| - toString |
| - typedef |
| TikaIO: |
| methods: |
| - expand |
| - filepattern |
| - parse |
| - parseFiles |
| - populateDisplayData |
| - processElement |
| - setup |
| - withContentTypeHint |
| - withInputMetadata |
| - withTikaConfigPath |
| Time: |
| methods: |
| - getArgument |
| - getArgumentType |
| - getBaseType |
| - getIdentifier |
| - toBaseType |
| - toInputType |
| properties: |
| - IDENTIFIER |
| TimeMonitor: |
| methods: |
| - processElement |
| TimeUtil: |
| methods: |
| - toJava |
| - toJoda |
| TimerEndpoint: |
| methods: |
| - create |
| - getCoder |
| - getReceiver |
| - getTimerFamilyId |
| - getTransformId |
| TimerSpecs: |
| methods: |
| - getTimeDomain |
| - timer |
| - timerMap |
| TimestampEncoding: {} |
| TimestampExtractTransform: |
| methods: |
| - expand |
| - of |
| - processElement |
| TimestampFunctions: |
| methods: |
| - timestamp |
| TimestampPolicy: |
| methods: |
| - getBacklogCheckTime |
| - getMessageBacklog |
| - getTimestampForRecord |
| - getWatermark |
| TimestampPrefixingWindowCoder: |
| methods: |
| - consistentWithEquals |
| - decode |
| - encode |
| - getCoderArguments |
| - getWindowCoder |
| - isRegisterByteSizeObserverCheap |
| - of |
| - registerByteSizeObserver |
| - verifyDeterministic |
| TimestampRange: |
| methods: |
| - equals |
| - getFrom |
| - getTo |
| - hashCode |
| - of |
| - toString |
| TimestampRangeTracker: |
| methods: |
| - checkDone |
| - currentRestriction |
| - getProgress |
| - isBounded |
| - setTimeSupplier |
| - tryClaim |
| - trySplit |
| TimestampTransform: |
| methods: |
| - alignTo |
| - delay |
| - getDelay |
| - getOffset |
| - getPeriod |
| TimestampUtils: |
| methods: |
| - next |
| - previous |
| - toNanos |
| - toTimestamp |
| TimestampedValue: |
| methods: |
| - atMinimumTimestamp |
| - decode |
| - encode |
| - equals |
| - getCoderArguments |
| - getComponents |
| - getEncodedTypeDescriptor |
| - getTimestamp |
| - getValue |
| - getValueCoder |
| - hashCode |
| - of |
| - structuralValue |
| - toString |
| - verifyDeterministic |
| ToJson: |
| methods: |
| - expand |
| - of |
| - processElement |
| ToString: |
| methods: |
| - apply |
| - elements |
| - expand |
| - iterables |
| - kvs |
| ToStringFnRunner: |
| methods: |
| - getPTransformRunnerFactories |
| Top: |
| methods: |
| - addInput |
| - compare |
| - createAccumulator |
| - decode |
| - encode |
| - equals |
| - extractOutput |
| - getAccumulatorCoder |
| - getIncompatibleGlobalWindowErrorMessage |
| - getNameOverride |
| - hashCode |
| - isRegisterByteSizeObserverCheap |
| - largest |
| - largestDoublesFn |
| - largestFn |
| - largestIntsFn |
| - largestLongsFn |
| - largestPerKey |
| - mergeAccumulator |
| - of |
| - perKey |
| - populateDisplayData |
| - registerByteSizeObserver |
| - smallest |
| - smallestDoublesFn |
| - smallestFn |
| - smallestIntsFn |
| - smallestLongsFn |
| - smallestPerKey |
| - verifyDeterministic |
| TopPerKey: |
| methods: |
| - accumulationMode |
| - expand |
| - getScoreExtractor |
| - getScoreType |
| - getValueExtractor |
| - getValueType |
| - keyBy |
| - named |
| - of |
| - output |
| - scoreBy |
| - triggeredBy |
| - valueBy |
| - windowBy |
| - withAllowedLateness |
| - withOnTimeBehavior |
| - withTimestampCombiner |
| TopicPartitionCoder: |
| methods: |
| - decode |
| - encode |
| - getCoderArguments |
| - verifyDeterministic |
| TpcdsOptionsRegistrar: |
| methods: |
| - getPipelineOptions |
| TpcdsParametersReader: |
| methods: |
| - getAndCheckDataSize |
| - getAndCheckQueryNames |
| - getAndCheckTpcParallel |
| properties: |
| - ALL_QUERY_NAMES |
| TpcdsRun: |
| methods: |
| - call |
| TpcdsRunResult: |
| methods: |
| - getDataSize |
| - getDialect |
| - getElapsedTime |
| - getEndDate |
| - getIsSuccessful |
| - getJobName |
| - getPipelineOptions |
| - getPipelineResult |
| - getQueryName |
| - getStartDate |
| TpcdsSchemas: |
| methods: |
| - getCallCenterSchema |
| - getCatalogPageSchema |
| - getCatalogReturnsSchema |
| - getCatalogSalesSchema |
| - getCustomerAddressSchema |
| - getCustomerDemographicsSchema |
| - getCustomerSchema |
| - getDateDimSchema |
| - getHouseholdDemographicsSchema |
| - getIncomeBandSchema |
| - getInventorySchema |
| - getItemSchema |
| - getPromotionSchema |
| - getReasonSchema |
| - getShipModeSchema |
| - getStoreReturnsSchema |
| - getStoreSalesSchema |
| - getStoreSchema |
| - getTimeDimSchema |
| - getTpcdsSchemas |
| - getTpcdsSchemasImmutableMap |
| - getWarehouseSchema |
| - getWebReturnsSchema |
| - getWebSalesSchema |
| - getWebSiteSchema |
| - getWebpageSchema |
| TpcdsUtils: {} |
| TrackerWithProgress: {} |
| Transaction: |
| methods: |
| - create |
| - transactionId |
| TransformHierarchy: |
| methods: |
| - addComposite |
| - finishSpecifyingInput |
| - getCurrent |
| - getEnclosingNode |
| - getFullName |
| - getInputs |
| - getOutputs |
| - getTransform |
| - isCompositeNode |
| - isRootNode |
| - popNode |
| - pushNode |
| - replaceChild |
| - replaceNode |
| - replaceOutputs |
| - setOutput |
| - toAppliedPTransform |
| - toString |
| - visit |
| Transport: |
| methods: |
| - getJsonFactory |
| - getTransport |
| - newStorageClient |
| properties: |
| - rootUrl |
| - servicePath |
| Trigger: |
| methods: |
| - equals |
| - getContinuationTrigger |
| - getWatermarkThatGuaranteesFiring |
| - hashCode |
| - isCompatible |
| - mayFinish |
| - orFinally |
| - subTriggers |
| - toString |
| Triple: |
| methods: |
| - equals |
| - getFirst |
| - getSecond |
| - getThird |
| - hashCode |
| - of |
| - toString |
| TupleTag: |
| methods: |
| - equals |
| - getId |
| - getOutName |
| - getTypeDescriptor |
| - hashCode |
| - toString |
| TupleTagList: |
| methods: |
| - and |
| - empty |
| - get |
| - getAll |
| - of |
| - size |
| - toString |
| TypeAware: {} |
| TypeAwareness: |
| methods: |
| - orObjects |
| TypeCode: |
| methods: |
| - equals |
| - getCode |
| - hashCode |
| - toString |
| TypeDescriptor: |
| methods: |
| - equals |
| - getArgumentTypes |
| - getClasses |
| - getComponentType |
| - getInterfaces |
| - getRawType |
| - getSupertype |
| - getType |
| - getTypeParameter |
| - getTypes |
| - hasUnresolvedParameters |
| - hashCode |
| - isArray |
| - isSubtypeOf |
| - isSupertypeOf |
| - of |
| - resolveType |
| - toString |
| - where |
| TypeDescriptors: |
| methods: |
| - bigdecimals |
| - bigintegers |
| - booleans |
| - bytes |
| - characters |
| - doubles |
| - extractFromTypeParameters |
| - floats |
| - inputOf |
| - integers |
| - iterables |
| - kvs |
| - lists |
| - longs |
| - maps |
| - nulls |
| - outputOf |
| - rows |
| - sets |
| - shorts |
| - strings |
| - voids |
| TypeParameter: |
| methods: |
| - equals |
| - hashCode |
| - toString |
| TypeUtils: |
| methods: |
| - keyValues |
| - triplets |
| TypedCombineFnDelegate: |
| methods: |
| - addInput |
| - apply |
| - compact |
| - createAccumulator |
| - defaultValue |
| - extractOutput |
| - getAccumTVariable |
| - getAccumulatorCoder |
| - getDefaultOutputCoder |
| - getIncompatibleGlobalWindowErrorMessage |
| - getInputTVariable |
| - getInputType |
| - getOutputTVariable |
| - getOutputType |
| - mergeAccumulators |
| - populateDisplayData |
| TypedSchemaTransformProvider: |
| methods: |
| - configurationSchema |
| - dependencies |
| - from |
| UdafImpl: |
| methods: |
| - getCombineFn |
| - getImplementor |
| - getName |
| - getOrdinal |
| - getParameters |
| - getReturnType |
| - getType |
| - isOptional |
| UdfImplReflectiveFunctionBase: |
| methods: |
| - add |
| - addMethodParameters |
| - build |
| - builder |
| - getName |
| - getOrdinal |
| - getParameters |
| - getType |
| - isOptional |
| properties: |
| - method |
| - parameters |
| UdfTestProvider: |
| methods: |
| - addInput |
| - createAccumulator |
| - extractOutput |
| - helloWorld |
| - increment |
| - incrementAll |
| - isNull |
| - matches |
| - mergeAccumulators |
| - notRegistered |
| - userDefinedAggregateFunctions |
| - userDefinedScalarFunctions |
| UnboundedEventSource: |
| methods: |
| - advance |
| - close |
| - createReader |
| - getCheckpointMark |
| - getCheckpointMarkCoder |
| - getCurrent |
| - getCurrentSource |
| - getCurrentTimestamp |
| - getDefaultOutputCoder |
| - getSplitBacklogBytes |
| - getWatermark |
| - split |
| - start |
| - toString |
| - validate |
| UnboundedReaderImpl: |
| methods: |
| - advance |
| - close |
| - getCheckpointMark |
| - getCurrent |
| - getCurrentSource |
| - getCurrentTimestamp |
| - getSplitBacklogBytes |
| - getWatermark |
| - start |
| UnboundedScheduledExecutorService: |
| methods: |
| - awaitTermination |
| - call |
| - cancel |
| - compareTo |
| - execute |
| - getDelay |
| - invokeAll |
| - invokeAny |
| - isPeriodic |
| - isShutdown |
| - isTerminated |
| - run |
| - schedule |
| - scheduleAtFixedRate |
| - scheduleWithFixedDelay |
| - shutdown |
| - shutdownNow |
| - submit |
| UnboundedSource: |
| methods: |
| - advance |
| - createReader |
| - finalizeCheckpoint |
| - getCheckpointMark |
| - getCheckpointMarkCoder |
| - getCurrentRecordId |
| - getCurrentSource |
| - getSplitBacklogBytes |
| - getTotalBacklogBytes |
| - getWatermark |
| - requiresDeduping |
| - split |
| - start |
| properties: |
| - BACKLOG_UNKNOWN |
| UnboundedSourceImpl: |
| methods: |
| - createReader |
| - getCheckpointMarkCoder |
| - getOutputCoder |
| - split |
| Union: |
| methods: |
| - named |
| - of |
| - output |
| UnionCoder: |
| methods: |
| - decode |
| - encode |
| - getCoderArguments |
| - getComponents |
| - getElementCoders |
| - isRegisterByteSizeObserverCheap |
| - of |
| - registerByteSizeObserver |
| - verifyDeterministic |
| UnionTranslator: |
| methods: |
| - translate |
| UnknownLogicalType: |
| methods: |
| - getPayload |
| UnownedInputStream: |
| methods: |
| - close |
| - equals |
| - hashCode |
| - mark |
| - markSupported |
| - reset |
| - toString |
| UnownedOutputStream: |
| methods: |
| - close |
| - equals |
| - hashCode |
| - toString |
| - write |
| UnsignedOptions: |
| methods: |
| - build |
| - builder |
| - setUint16Behavior |
| - setUint32Behavior |
| - setUint64Behavior |
| - setUint8Behavior |
| - toBuilder |
| - uint16Behavior |
| - uint32Behavior |
| - uint64Behavior |
| - uint8Behavior |
| - usingHigherBitSize |
| - usingSameBitSize |
| UpdateConfiguration: |
| methods: |
| - create |
| - withFindKey |
| - withIsUpsert |
| - withUpdateFields |
| - withUpdateKey |
| UpdateField: |
| methods: |
| - fieldUpdate |
| - fullUpdate |
| UpdateSchemaDestination: |
| methods: |
| - finishBundle |
| - onTeardown |
| - processElement |
| - startBundle |
| UploadIdResponseInterceptor: |
| methods: |
| - interceptResponse |
| UserCodeException: |
| methods: |
| - wrap |
| - wrapIf |
| UserFunctionDefinitions: |
| methods: |
| - build |
| - create |
| - jarPath |
| - javaAggregateFunctions |
| - javaScalarFunctions |
| - method |
| - newBuilder |
| - setJavaAggregateFunctions |
| - setJavaScalarFunctions |
| - setSqlScalarFunctions |
| - setSqlTableValuedFunctions |
| - sqlScalarFunctions |
| - sqlTableValuedFunctions |
| UsesAttemptedMetrics: {} |
| UsesCounterMetrics: {} |
| UsesDistributionMetrics: {} |
| UsesGaugeMetrics: {} |
| UsesImpulse: {} |
| UsesOrderedListState: {} |
| Uuid: |
| methods: |
| - of |
| - random |
| - value |
| properties: |
| - DEFAULT_ATTRIBUTE |
| UuidCoder: |
| methods: |
| - decode |
| - encode |
| - getCoderProvider |
| UuidDeduplicationOptions: |
| methods: |
| - build |
| - deduplicate |
| - newBuilder |
| - setDeduplicate |
| - setUuidExtractor |
| - uuidExtractor |
| properties: |
| - DEFAULT_DEDUPLICATE_DURATION |
| - DEFAULT_TIME_DOMAIN |
| - DEFAULT_UUID_EXTRACTOR |
| UuidDeduplicationTransform: |
| methods: |
| - expand |
| UuidLogicalType: |
| methods: |
| - getArgument |
| - getArgumentType |
| - getBaseType |
| - getIdentifier |
| - toBaseType |
| - toInputType |
| properties: |
| - IDENTIFIER |
| - LEAST_SIGNIFICANT_BITS_FIELD_NAME |
| - MOST_SIGNIFICANT_BITS_FIELD_NAME |
| - UUID_SCHEMA |
| ValueInSingleWindow: |
| methods: |
| - decode |
| - encode |
| - getCoderArguments |
| - getComponents |
| - getPane |
| - getTimestamp |
| - getValue |
| - getWindow |
| - of |
| - verifyDeterministic |
| ValueProviders: |
| methods: |
| - updateSerializedOptions |
| ValueWithRecordId: |
| methods: |
| - decode |
| - encode |
| - equals |
| - getCoderArguments |
| - getId |
| - getValue |
| - getValueCoder |
| - hashCode |
| - of |
| - processElement |
| - toString |
| - verifyDeterministic |
| Values: |
| methods: |
| - apply |
| - create |
| - expand |
| VarInt: |
| methods: |
| - decodeInt |
| - decodeLong |
| - encode |
| - getLength |
| VarIntCoder: |
| methods: |
| - consistentWithEquals |
| - decode |
| - encode |
| - getEncodedTypeDescriptor |
| - isRegisterByteSizeObserverCheap |
| - of |
| - verifyDeterministic |
| VarLongCoder: |
| methods: |
| - consistentWithEquals |
| - decode |
| - encode |
| - getCoderArguments |
| - getEncodedTypeDescriptor |
| - isRegisterByteSizeObserverCheap |
| - of |
| - verifyDeterministic |
| VariableBytes: |
| methods: |
| - getMaxLength |
| - getName |
| - of |
| - toInputType |
| - toString |
| properties: |
| - IDENTIFIER |
| VariableString: |
| methods: |
| - getMaxLength |
| - getName |
| - of |
| - toInputType |
| - toString |
| properties: |
| - IDENTIFIER |
| VarianceFn: |
| methods: |
| - addInput |
| - createAccumulator |
| - extractOutput |
| - getAccumulatorCoder |
| - mergeAccumulators |
| - newPopulation |
| - newSample |
| VideoIntelligence: |
| methods: |
| - annotateFromBytes |
| - annotateFromBytesWithContext |
| - annotateFromURI |
| - annotateFromUriWithContext |
| - expand |
| View: |
| methods: |
| - apply |
| - asIterable |
| - asList |
| - asMap |
| - asMultimap |
| - asSingleton |
| - defaultValue |
| - expand |
| - finishBundle |
| - getView |
| - hasDefaultValue |
| - identity |
| - of |
| - processElement |
| - withDefaultValue |
| - withSingletonValues |
| ViewFn: |
| methods: |
| - apply |
| - getMaterialization |
| - getTypeDescriptor |
| VoidAccumulatorProvider: |
| methods: |
| - add |
| - create |
| - get |
| - getCounter |
| - getFactory |
| - getHistogram |
| - getTimer |
| - increment |
| VoidCoder: |
| methods: |
| - decode |
| - encode |
| - getEncodedTypeDescriptor |
| - isRegisterByteSizeObserverCheap |
| - of |
| - structuralValue |
| - verifyDeterministic |
| Wait: |
| methods: |
| - expand |
| - finishBundle |
| - on |
| - process |
| - startBundle |
| Watch: |
| methods: |
| - afterIterations |
| - afterTimeSinceNewOutput |
| - afterTotalOf |
| - allOf |
| - canStopPolling |
| - checkDone |
| - complete |
| - currentRestriction |
| - decode |
| - eitherOf |
| - encode |
| - equals |
| - expand |
| - forNewInput |
| - getCoderArguments |
| - getCompleted |
| - getInitialRestriction |
| - getInitialWatermarkEstimatorState |
| - getPending |
| - getPollWatermark |
| - getRestrictionCoder |
| - getStateCoder |
| - getTerminationState |
| - growthOf |
| - hashCode |
| - ignoreInput |
| - incomplete |
| - isBounded |
| - never |
| - newTracker |
| - newWatermarkEstimator |
| - of |
| - onPollComplete |
| - onSeenNewOutput |
| - process |
| - processElement |
| - toString |
| - tryClaim |
| - trySplit |
| - verifyDeterministic |
| - withOutputCoder |
| - withOutputKeyCoder |
| - withOutputs |
| - withPollInterval |
| - withTerminationPerInput |
| - withWatermark |
| WatermarkEstimators: |
| methods: |
| - currentWatermark |
| - getState |
| - getWatermarkAndState |
| - observeTimestamp |
| - setWatermark |
| - threadSafe |
| WatermarkLatency: |
| methods: |
| - main |
| - process |
| WatermarkParameters: |
| methods: |
| - builder |
| - create |
| - toBuilder |
| - withTimestampFn |
| - withWatermarkIdleDurationThreshold |
| WebPathParser: |
| methods: |
| - parseDicomWebpath |
| properties: |
| - dataset |
| - dicomStorePath |
| - instanceId |
| - location |
| - project |
| - seriesId |
| - storeId |
| - studyId |
| WeightedValue: |
| methods: |
| - equals |
| - getValue |
| - getWeight |
| - hashCode |
| - of |
| - toString |
| Window: |
| methods: |
| - accumulatingFiredPanes |
| - apply |
| - configure |
| - discardingFiredPanes |
| - expand |
| - getOutputStrategyInternal |
| - getWindowFn |
| - into |
| - populateDisplayData |
| - remerge |
| - triggering |
| - withAllowedLateness |
| - withOnTimeBehavior |
| - withTimestampCombiner |
| WindowFn: |
| methods: |
| - assignWindows |
| - assignsToOneWindow |
| - element |
| - getDefaultWindowMappingFn |
| - getWindowTypeDescriptor |
| - isCompatible |
| - isNonMerging |
| - merge |
| - mergeWindows |
| - populateDisplayData |
| - timestamp |
| - verifyCompatibility |
| - window |
| - windowCoder |
| - windows |
| WindowFnTestUtils: |
| methods: |
| - assignedWindows |
| - assignedWindowsWithValue |
| - element |
| - get |
| - merge |
| - put |
| - runWindowFn |
| - runWindowFnWithValue |
| - set |
| - timestamp |
| - validateGetOutputTimestamps |
| - validateGetOutputTimestampsWithValue |
| - window |
| - windows |
| WindowMappingFn: |
| methods: |
| - getSideInputWindow |
| - maximumLookback |
| WindowMappingFnRunner: |
| methods: |
| - getPTransformRunnerFactories |
| WindowMergingFnRunner: |
| methods: |
| - getPTransformRunnerFactories |
| - merge |
| - windows |
| WindowTracing: |
| methods: |
| - debug |
| - trace |
| WindowedValue: |
| methods: |
| - decode |
| - encode |
| - equals |
| - explodeWindows |
| - fromComponents |
| - getCoderArguments |
| - getComponents |
| - getFullCoder |
| - getPane |
| - getParamWindowedValueCoder |
| - getPayload |
| - getTimestamp |
| - getValue |
| - getValueCoder |
| - getValueOnlyCoder |
| - getWindow |
| - getWindowCoder |
| - getWindows |
| - getWindowsCoder |
| - hashCode |
| - isSingleWindowedValue |
| - of |
| - registerByteSizeObserver |
| - timestampedValueInGlobalWindow |
| - toString |
| - valueInGlobalWindow |
| - verifyDeterministic |
| - withValue |
| - withValueCoder |
| WindowingStrategy: |
| methods: |
| - equals |
| - fixDefaults |
| - getAllowedLateness |
| - getClosingBehavior |
| - getEnvironmentId |
| - getMode |
| - getOnTimeBehavior |
| - getTimestampCombiner |
| - getTrigger |
| - getWindowFn |
| - globalDefault |
| - hashCode |
| - isAllowedLatenessSpecified |
| - isAlreadyMerged |
| - isModeSpecified |
| - isTimestampCombinerSpecified |
| - isTriggerSpecified |
| - needsMerge |
| - of |
| - toString |
| - withAllowedLateness |
| - withAlreadyMerged |
| - withClosingBehavior |
| - withEnvironmentId |
| - withMode |
| - withOnTimeBehavior |
| - withTimestampCombiner |
| - withTrigger |
| - withWindowFn |
| WinningBids: |
| methods: |
| - assignWindows |
| - decode |
| - encode |
| - equals |
| - expand |
| - forAuction |
| - forBid |
| - getDefaultWindowMappingFn |
| - hashCode |
| - isAuctionWindow |
| - isCompatible |
| - mergeWindows |
| - of |
| - processElement |
| - structuralValue |
| - toString |
| - verifyDeterministic |
| - windowCoder |
| properties: |
| - auction |
| - isAuctionWindow |
| WinningBidsSimulator: {} |
| WithFailures: |
| methods: |
| - apply |
| - element |
| - exception |
| - expand |
| - failures |
| - failuresTo |
| - finishSpecifyingOutput |
| - getPipeline |
| - of |
| - output |
| WithKeys: |
| methods: |
| - apply |
| - expand |
| - of |
| - process |
| - withKeyType |
| WithTimestamps: |
| methods: |
| - expand |
| - getAllowedTimestampSkew |
| - of |
| - processElement |
| - withAllowedTimestampSkew |
| WordCount: |
| methods: |
| - apply |
| - expand |
| - main |
| - processElement |
| WrappedSupervisor: |
| methods: |
| - createBlockGenerator |
| - getCurrentRateLimit |
| - isReceiverStopped |
| - logInfo |
| - onReceiverStart |
| - pushArrayBuffer |
| - pushBytes |
| - pushIterator |
| - pushSingle |
| - reportError |
| WritableCoder: |
| methods: |
| - coderFor |
| - decode |
| - encode |
| - equals |
| - getCoderArguments |
| - getCoderProvider |
| - getCoderProviders |
| - hashCode |
| - of |
| - verifyDeterministic |
| WriteBuilder: |
| methods: |
| - buildExternal |
| - getCreateDisposition |
| - getTableSchema |
| - getWriteDisposition |
| - setCreateDisposition |
| - setTableSchema |
| - setWriteDisposition |
| WriteFiles: |
| methods: |
| - apply |
| - assignShardKey |
| - equals |
| - expand |
| - finishBundle |
| - getAdditionalInputs |
| - getComputeNumShards |
| - getNumShardsProvider |
| - getShardingFunction |
| - getSink |
| - getWindowedWrites |
| - hashCode |
| - populateDisplayData |
| - process |
| - processElement |
| - startBundle |
| - to |
| - validate |
| - withMaxNumWritersPerBundle |
| - withNoSpilling |
| - withNumShards |
| - withRunnerDeterminedSharding |
| - withSharding |
| - withShardingFunction |
| - withSideInputs |
| - withSkipIfEmpty |
| - withWindowedWrites |
| properties: |
| - CONCRETE_CLASS |
| WriteFilesResult: |
| methods: |
| - expand |
| - finishSpecifyingOutput |
| - getPerDestinationOutputFilenames |
| - getPipeline |
| WriteJmsResult: |
| methods: |
| - expand |
| - finishSpecifyingOutput |
| - getFailedMessages |
| - getPipeline |
| WriteResult: |
| methods: |
| - expand |
| - finishSpecifyingOutput |
| - getFailedInserts |
| - getFailedInsertsWithErr |
| - getFailedStorageApiInserts |
| - getPipeline |
| - getSuccessfulInserts |
| - getSuccessfulTableLoads |
| WriteToPulsarDoFn: |
| methods: |
| - processElement |
| - setup |
| - teardown |
| XmlIO: |
| methods: |
| - apply |
| - expand |
| - flush |
| - from |
| - matches |
| - open |
| - populateDisplayData |
| - read |
| - readFiles |
| - sink |
| - to |
| - withCharset |
| - withCompression |
| - withCompressionType |
| - withMinBundleSize |
| - withRecordClass |
| - withRecordElement |
| - withRootElement |
| - withValidationEventHandler |
| - write |
| XmlSource: |
| methods: |
| - getCurrent |
| - getCurrentSource |
| - getOutputCoder |
| ZetaSQLQueryPlanner: |
| methods: |
| - convertToBeamRel |
| - createPlanner |
| - getDefaultTimezone |
| - getLanguageOptions |
| - getZetaSqlRuleSets |
| - parse |
| - setDefaultTimezone |
| properties: |
| - DEFAULT_CALC |
| - FACTORY |
| ZetaSqlBeamTranslationUtils: |
| methods: |
| - toBeamObject |
| - toBeamRow |
| - toBeamType |
| - toZetaSqlStructType |
| - toZetaSqlStructValue |
| - toZetaSqlType |
| - toZetaSqlValue |
| ZetaSqlCalciteTranslationUtils: |
| methods: |
| - toCalciteType |
| - toRexNode |
| - toZetaSqlType |
| properties: |
| - ZETASQL_NUMERIC_MAX_VALUE |
| - ZETASQL_NUMERIC_MIN_VALUE |
| - ZETASQL_NUMERIC_SCALE |
| ZetaSqlException: {} |
| ZetaSqlScalarFunctionImpl: |
| methods: |
| - create |
| properties: |
| - functionGroup |
| ZetaSqlUnnest: |
| methods: |
| - copy |
| - create |
| - deriveUncollectRowType |
| - explainTerms |
| properties: |
| - withOrdinality |
| ZetaSqlUserDefinedSQLNativeTableValuedFunction: {} |
| ZipFiles: |
| methods: |
| - iterator |
| - openStream |
| - toString |
| - zipDirectory |
| - zipDirectoryOverwrite |
| ZstdCoder: |
| methods: |
| - consistentWithEquals |
| - decode |
| - encode |
| - equals |
| - getCoderArguments |
| - hashCode |
| - of |
| - structuralValue |
| - toString |
| - verifyDeterministic |
