jar

org.apache.flink : flink-table-common

Maven & Gradle

May 19, 2023
198 usages
21.5k stars

Flink : Table : Common · This module contains extension points of the Table/SQL API. It allows for implementing user-defined functions, custom formats, etc. with minimal dependencies.

Table Of Contents

Latest Version

Download org.apache.flink : flink-table-common JAR file - Latest Versions:

All Versions

Download org.apache.flink : flink-table-common JAR file - All Versions:

Version Vulnerabilities Size Updated
1.17.x
1.16.x
1.15.x
1.14.x
1.13.x
1.12.x
1.11.x
1.10.x
1.9.x
1.8.x
1.7.x

View Java Class Source Code in JAR file

  1. Download JD-GUI to open JAR file and explore Java source code file (.class .java)
  2. Click menu "File → Open File..." or just drag-and-drop the JAR file in the JD-GUI window flink-table-common-1.17.1.jar file.
    Once you open a JAR file, all the java classes in the JAR file will be displayed.

org.apache.flink.table.plan.stats

├─ org.apache.flink.table.plan.stats.ColumnStats.class - [JAR]

├─ org.apache.flink.table.plan.stats.TableStats.class - [JAR]

org.apache.flink.table.connector

├─ org.apache.flink.table.connector.ChangelogMode.class - [JAR]

├─ org.apache.flink.table.connector.ParallelismProvider.class - [JAR]

├─ org.apache.flink.table.connector.Projection.class - [JAR]

├─ org.apache.flink.table.connector.RequireCatalogLock.class - [JAR]

├─ org.apache.flink.table.connector.RowLevelModificationScanContext.class - [JAR]

├─ org.apache.flink.table.connector.RuntimeConverter.class - [JAR]

org.apache.flink.table.data

├─ org.apache.flink.table.data.ArrayData.class - [JAR]

├─ org.apache.flink.table.data.DecimalData.class - [JAR]

├─ org.apache.flink.table.data.GenericArrayData.class - [JAR]

├─ org.apache.flink.table.data.GenericMapData.class - [JAR]

├─ org.apache.flink.table.data.GenericRowData.class - [JAR]

├─ org.apache.flink.table.data.MapData.class - [JAR]

├─ org.apache.flink.table.data.RawValueData.class - [JAR]

├─ org.apache.flink.table.data.RowData.class - [JAR]

├─ org.apache.flink.table.data.StringData.class - [JAR]

├─ org.apache.flink.table.data.TimestampData.class - [JAR]

org.apache.flink.table.data.columnar.vector

├─ org.apache.flink.table.data.columnar.vector.ArrayColumnVector.class - [JAR]

├─ org.apache.flink.table.data.columnar.vector.BooleanColumnVector.class - [JAR]

├─ org.apache.flink.table.data.columnar.vector.ByteColumnVector.class - [JAR]

├─ org.apache.flink.table.data.columnar.vector.BytesColumnVector.class - [JAR]

├─ org.apache.flink.table.data.columnar.vector.ColumnVector.class - [JAR]

├─ org.apache.flink.table.data.columnar.vector.DecimalColumnVector.class - [JAR]

├─ org.apache.flink.table.data.columnar.vector.Dictionary.class - [JAR]

├─ org.apache.flink.table.data.columnar.vector.DoubleColumnVector.class - [JAR]

├─ org.apache.flink.table.data.columnar.vector.FloatColumnVector.class - [JAR]

├─ org.apache.flink.table.data.columnar.vector.IntColumnVector.class - [JAR]

├─ org.apache.flink.table.data.columnar.vector.LongColumnVector.class - [JAR]

├─ org.apache.flink.table.data.columnar.vector.MapColumnVector.class - [JAR]

├─ org.apache.flink.table.data.columnar.vector.RowColumnVector.class - [JAR]

├─ org.apache.flink.table.data.columnar.vector.ShortColumnVector.class - [JAR]

├─ org.apache.flink.table.data.columnar.vector.TimestampColumnVector.class - [JAR]

├─ org.apache.flink.table.data.columnar.vector.VectorizedColumnBatch.class - [JAR]

org.apache.flink.table.connector.sink

├─ org.apache.flink.table.connector.sink.DynamicTableSink.class - [JAR]

├─ org.apache.flink.table.connector.sink.OutputFormatProvider.class - [JAR]

├─ org.apache.flink.table.connector.sink.SinkProvider.class - [JAR]

├─ org.apache.flink.table.connector.sink.SinkV2Provider.class - [JAR]

org.apache.flink.table.factories

├─ org.apache.flink.table.factories.AmbiguousTableFactoryException.class - [JAR]

├─ org.apache.flink.table.factories.CatalogFactory.class - [JAR]

├─ org.apache.flink.table.factories.DecodingFormatFactory.class - [JAR]

├─ org.apache.flink.table.factories.DeserializationFormatFactory.class - [JAR]

├─ org.apache.flink.table.factories.DynamicTableFactory.class - [JAR]

├─ org.apache.flink.table.factories.DynamicTableSinkFactory.class - [JAR]

├─ org.apache.flink.table.factories.DynamicTableSourceFactory.class - [JAR]

├─ org.apache.flink.table.factories.EncodingFormatFactory.class - [JAR]

├─ org.apache.flink.table.factories.Factory.class - [JAR]

├─ org.apache.flink.table.factories.FactoryUtil.class - [JAR]

├─ org.apache.flink.table.factories.FormatFactory.class - [JAR]

├─ org.apache.flink.table.factories.FunctionDefinitionFactory.class - [JAR]

├─ org.apache.flink.table.factories.ManagedTableFactory.class - [JAR]

├─ org.apache.flink.table.factories.ModuleFactory.class - [JAR]

├─ org.apache.flink.table.factories.NoMatchingTableFactoryException.class - [JAR]

├─ org.apache.flink.table.factories.SerializationFormatFactory.class - [JAR]

├─ org.apache.flink.table.factories.TableFactory.class - [JAR]

├─ org.apache.flink.table.factories.TableFactoryService.class - [JAR]

├─ org.apache.flink.table.factories.TableSinkFactory.class - [JAR]

├─ org.apache.flink.table.factories.TableSinkFactoryContextImpl.class - [JAR]

├─ org.apache.flink.table.factories.TableSourceFactory.class - [JAR]

├─ org.apache.flink.table.factories.TableSourceFactoryContextImpl.class - [JAR]

org.apache.flink.table.api.constraints

├─ org.apache.flink.table.api.constraints.AbstractConstraint.class - [JAR]

├─ org.apache.flink.table.api.constraints.Constraint.class - [JAR]

├─ org.apache.flink.table.api.constraints.UniqueConstraint.class - [JAR]

org.apache.flink.table.annotation

├─ org.apache.flink.table.annotation.DataTypeHint.class - [JAR]

├─ org.apache.flink.table.annotation.ExtractionVersion.class - [JAR]

├─ org.apache.flink.table.annotation.FunctionHint.class - [JAR]

├─ org.apache.flink.table.annotation.FunctionHints.class - [JAR]

├─ org.apache.flink.table.annotation.HintFlag.class - [JAR]

├─ org.apache.flink.table.annotation.InputGroup.class - [JAR]

├─ org.apache.flink.table.annotation.UnknownSerializer.class - [JAR]

org.apache.flink.table.types

├─ org.apache.flink.table.types.AbstractDataType.class - [JAR]

├─ org.apache.flink.table.types.AtomicDataType.class - [JAR]

├─ org.apache.flink.table.types.CollectionDataType.class - [JAR]

├─ org.apache.flink.table.types.DataType.class - [JAR]

├─ org.apache.flink.table.types.DataTypeQueryable.class - [JAR]

├─ org.apache.flink.table.types.DataTypeVisitor.class - [JAR]

├─ org.apache.flink.table.types.FieldsDataType.class - [JAR]

├─ org.apache.flink.table.types.KeyValueDataType.class - [JAR]

├─ org.apache.flink.table.types.UnresolvedDataType.class - [JAR]

org.apache.flink.table.types.logical

├─ org.apache.flink.table.types.logical.ArrayType.class - [JAR]

├─ org.apache.flink.table.types.logical.BigIntType.class - [JAR]

├─ org.apache.flink.table.types.logical.BinaryType.class - [JAR]

├─ org.apache.flink.table.types.logical.BooleanType.class - [JAR]

├─ org.apache.flink.table.types.logical.CharType.class - [JAR]

├─ org.apache.flink.table.types.logical.DateType.class - [JAR]

├─ org.apache.flink.table.types.logical.DayTimeIntervalType.class - [JAR]

├─ org.apache.flink.table.types.logical.DecimalType.class - [JAR]

├─ org.apache.flink.table.types.logical.DistinctType.class - [JAR]

├─ org.apache.flink.table.types.logical.DoubleType.class - [JAR]

├─ org.apache.flink.table.types.logical.FloatType.class - [JAR]

├─ org.apache.flink.table.types.logical.IntType.class - [JAR]

├─ org.apache.flink.table.types.logical.LegacyTypeInformationType.class - [JAR]

├─ org.apache.flink.table.types.logical.LocalZonedTimestampType.class - [JAR]

├─ org.apache.flink.table.types.logical.LogicalType.class - [JAR]

├─ org.apache.flink.table.types.logical.LogicalTypeFamily.class - [JAR]

├─ org.apache.flink.table.types.logical.LogicalTypeRoot.class - [JAR]

├─ org.apache.flink.table.types.logical.LogicalTypeVisitor.class - [JAR]

├─ org.apache.flink.table.types.logical.MapType.class - [JAR]

├─ org.apache.flink.table.types.logical.MultisetType.class - [JAR]

├─ org.apache.flink.table.types.logical.NullType.class - [JAR]

├─ org.apache.flink.table.types.logical.RawType.class - [JAR]

├─ org.apache.flink.table.types.logical.RowType.class - [JAR]

├─ org.apache.flink.table.types.logical.SmallIntType.class - [JAR]

├─ org.apache.flink.table.types.logical.StructuredType.class - [JAR]

├─ org.apache.flink.table.types.logical.SymbolType.class - [JAR]

├─ org.apache.flink.table.types.logical.TimeType.class - [JAR]

├─ org.apache.flink.table.types.logical.TimestampKind.class - [JAR]

├─ org.apache.flink.table.types.logical.TimestampType.class - [JAR]

├─ org.apache.flink.table.types.logical.TinyIntType.class - [JAR]

├─ org.apache.flink.table.types.logical.TypeInformationRawType.class - [JAR]

├─ org.apache.flink.table.types.logical.UnresolvedUserDefinedType.class - [JAR]

├─ org.apache.flink.table.types.logical.UserDefinedType.class - [JAR]

├─ org.apache.flink.table.types.logical.VarBinaryType.class - [JAR]

├─ org.apache.flink.table.types.logical.VarCharType.class - [JAR]

├─ org.apache.flink.table.types.logical.YearMonthIntervalType.class - [JAR]

├─ org.apache.flink.table.types.logical.ZonedTimestampType.class - [JAR]

org.apache.flink.table.dataview

├─ org.apache.flink.table.dataview.ListViewSerializer.class - [JAR]

├─ org.apache.flink.table.dataview.ListViewSerializerSnapshot.class - [JAR]

├─ org.apache.flink.table.dataview.ListViewTypeInfo.class - [JAR]

├─ org.apache.flink.table.dataview.ListViewTypeInfoFactory.class - [JAR]

├─ org.apache.flink.table.dataview.MapViewSerializer.class - [JAR]

├─ org.apache.flink.table.dataview.MapViewSerializerSnapshot.class - [JAR]

├─ org.apache.flink.table.dataview.MapViewTypeInfo.class - [JAR]

├─ org.apache.flink.table.dataview.MapViewTypeInfoFactory.class - [JAR]

├─ org.apache.flink.table.dataview.NullAwareMapSerializer.class - [JAR]

├─ org.apache.flink.table.dataview.NullAwareMapSerializerSnapshot.class - [JAR]

├─ org.apache.flink.table.dataview.NullSerializer.class - [JAR]

org.apache.flink.table.connector.format

├─ org.apache.flink.table.connector.format.DecodingFormat.class - [JAR]

├─ org.apache.flink.table.connector.format.EncodingFormat.class - [JAR]

├─ org.apache.flink.table.connector.format.FileBasedStatisticsReportableInputFormat.class - [JAR]

├─ org.apache.flink.table.connector.format.Format.class - [JAR]

├─ org.apache.flink.table.connector.format.ProjectableDecodingFormat.class - [JAR]

org.apache.flink.table.types.logical.utils

├─ org.apache.flink.table.types.logical.utils.LogicalTypeCasts.class - [JAR]

├─ org.apache.flink.table.types.logical.utils.LogicalTypeChecks.class - [JAR]

├─ org.apache.flink.table.types.logical.utils.LogicalTypeDefaultVisitor.class - [JAR]

├─ org.apache.flink.table.types.logical.utils.LogicalTypeDuplicator.class - [JAR]

├─ org.apache.flink.table.types.logical.utils.LogicalTypeMerging.class - [JAR]

├─ org.apache.flink.table.types.logical.utils.LogicalTypeParser.class - [JAR]

├─ org.apache.flink.table.types.logical.utils.LogicalTypeUtils.class - [JAR]

org.apache.flink.table.connector.sink.abilities

├─ org.apache.flink.table.connector.sink.abilities.SupportsDeletePushDown.class - [JAR]

├─ org.apache.flink.table.connector.sink.abilities.SupportsOverwrite.class - [JAR]

├─ org.apache.flink.table.connector.sink.abilities.SupportsPartitioning.class - [JAR]

├─ org.apache.flink.table.connector.sink.abilities.SupportsRowLevelDelete.class - [JAR]

├─ org.apache.flink.table.connector.sink.abilities.SupportsRowLevelUpdate.class - [JAR]

├─ org.apache.flink.table.connector.sink.abilities.SupportsWritingMetadata.class - [JAR]

org.apache.flink.table.sources

├─ org.apache.flink.table.sources.DefinedFieldMapping.class - [JAR]

├─ org.apache.flink.table.sources.DefinedProctimeAttribute.class - [JAR]

├─ org.apache.flink.table.sources.DefinedRowtimeAttributes.class - [JAR]

├─ org.apache.flink.table.sources.FieldComputer.class - [JAR]

├─ org.apache.flink.table.sources.FilterableTableSource.class - [JAR]

├─ org.apache.flink.table.sources.LimitableTableSource.class - [JAR]

├─ org.apache.flink.table.sources.LookupableTableSource.class - [JAR]

├─ org.apache.flink.table.sources.NestedFieldsProjectableTableSource.class - [JAR]

├─ org.apache.flink.table.sources.PartitionableTableSource.class - [JAR]

├─ org.apache.flink.table.sources.ProjectableTableSource.class - [JAR]

├─ org.apache.flink.table.sources.RowtimeAttributeDescriptor.class - [JAR]

├─ org.apache.flink.table.sources.TableSource.class - [JAR]

├─ org.apache.flink.table.sources.TableSourceValidation.class - [JAR]

org.apache.flink.table.catalog.stats

├─ org.apache.flink.table.catalog.stats.CatalogColumnStatistics.class - [JAR]

├─ org.apache.flink.table.catalog.stats.CatalogColumnStatisticsDataBase.class - [JAR]

├─ org.apache.flink.table.catalog.stats.CatalogColumnStatisticsDataBinary.class - [JAR]

├─ org.apache.flink.table.catalog.stats.CatalogColumnStatisticsDataBoolean.class - [JAR]

├─ org.apache.flink.table.catalog.stats.CatalogColumnStatisticsDataDate.class - [JAR]

├─ org.apache.flink.table.catalog.stats.CatalogColumnStatisticsDataDouble.class - [JAR]

├─ org.apache.flink.table.catalog.stats.CatalogColumnStatisticsDataLong.class - [JAR]

├─ org.apache.flink.table.catalog.stats.CatalogColumnStatisticsDataString.class - [JAR]

├─ org.apache.flink.table.catalog.stats.CatalogTableStatistics.class - [JAR]

├─ org.apache.flink.table.catalog.stats.Date.class - [JAR]

org.apache.flink.table.connector.source

├─ org.apache.flink.table.connector.source.AsyncTableFunctionProvider.class - [JAR]

├─ org.apache.flink.table.connector.source.DynamicFilteringData.class - [JAR]

├─ org.apache.flink.table.connector.source.DynamicFilteringEvent.class - [JAR]

├─ org.apache.flink.table.connector.source.DynamicTableSource.class - [JAR]

├─ org.apache.flink.table.connector.source.InputFormatProvider.class - [JAR]

├─ org.apache.flink.table.connector.source.LookupTableSource.class - [JAR]

├─ org.apache.flink.table.connector.source.ScanTableSource.class - [JAR]

├─ org.apache.flink.table.connector.source.SourceProvider.class - [JAR]

├─ org.apache.flink.table.connector.source.TableFunctionProvider.class - [JAR]

org.apache.flink.table.data.utils

├─ org.apache.flink.table.data.utils.CastExecutor.class - [JAR]

├─ org.apache.flink.table.data.utils.JoinedRowData.class - [JAR]

├─ org.apache.flink.table.data.utils.ProjectedRowData.class - [JAR]

org.apache.flink.table.types.extraction

├─ org.apache.flink.table.types.extraction.DataTypeExtractor.class - [JAR]

├─ org.apache.flink.table.types.extraction.DataTypeTemplate.class - [JAR]

├─ org.apache.flink.table.types.extraction.ExtractionUtils.class - [JAR]

├─ org.apache.flink.table.types.extraction.FunctionArgumentTemplate.class - [JAR]

├─ org.apache.flink.table.types.extraction.FunctionMappingExtractor.class - [JAR]

├─ org.apache.flink.table.types.extraction.FunctionResultTemplate.class - [JAR]

├─ org.apache.flink.table.types.extraction.FunctionSignatureTemplate.class - [JAR]

├─ org.apache.flink.table.types.extraction.FunctionTemplate.class - [JAR]

├─ org.apache.flink.table.types.extraction.TemplateUtils.class - [JAR]

├─ org.apache.flink.table.types.extraction.TypeInferenceExtractor.class - [JAR]

org.apache.flink.table.expressions

├─ org.apache.flink.table.expressions.AggregateExpression.class - [JAR]

├─ org.apache.flink.table.expressions.CallExpression.class - [JAR]

├─ org.apache.flink.table.expressions.Expression.class - [JAR]

├─ org.apache.flink.table.expressions.ExpressionDefaultVisitor.class - [JAR]

├─ org.apache.flink.table.expressions.ExpressionParserException.class - [JAR]

├─ org.apache.flink.table.expressions.ExpressionUtils.class - [JAR]

├─ org.apache.flink.table.expressions.ExpressionVisitor.class - [JAR]

├─ org.apache.flink.table.expressions.FieldReferenceExpression.class - [JAR]

├─ org.apache.flink.table.expressions.ResolvedExpression.class - [JAR]

├─ org.apache.flink.table.expressions.ResolvedFieldReference.class - [JAR]

├─ org.apache.flink.table.expressions.SqlCallExpression.class - [JAR]

├─ org.apache.flink.table.expressions.TableSymbol.class - [JAR]

├─ org.apache.flink.table.expressions.TimeIntervalUnit.class - [JAR]

├─ org.apache.flink.table.expressions.TimePointUnit.class - [JAR]

├─ org.apache.flink.table.expressions.TypeLiteralExpression.class - [JAR]

├─ org.apache.flink.table.expressions.ValueLiteralExpression.class - [JAR]

org.apache.flink.table.types.inference.utils

├─ org.apache.flink.table.types.inference.utils.AdaptedCallContext.class - [JAR]

├─ org.apache.flink.table.types.inference.utils.UnknownCallContext.class - [JAR]

org.apache.flink.table.api.dataview

├─ org.apache.flink.table.api.dataview.DataView.class - [JAR]

├─ org.apache.flink.table.api.dataview.ListView.class - [JAR]

├─ org.apache.flink.table.api.dataview.MapView.class - [JAR]

org.apache.flink.table.module

├─ org.apache.flink.table.module.CommonModuleOptions.class - [JAR]

├─ org.apache.flink.table.module.CoreModule.class - [JAR]

├─ org.apache.flink.table.module.CoreModuleFactory.class - [JAR]

├─ org.apache.flink.table.module.Module.class - [JAR]

├─ org.apache.flink.table.module.ModuleException.class - [JAR]

org.apache.flink.table.utils.print

├─ org.apache.flink.table.utils.print.PrintStyle.class - [JAR]

├─ org.apache.flink.table.utils.print.RawContentStyle.class - [JAR]

├─ org.apache.flink.table.utils.print.RowDataToStringConverter.class - [JAR]

├─ org.apache.flink.table.utils.print.TableauStyle.class - [JAR]

org.apache.flink.table.data.columnar.vector.heap

├─ org.apache.flink.table.data.columnar.vector.heap.AbstractHeapVector.class - [JAR]

├─ org.apache.flink.table.data.columnar.vector.heap.HeapArrayVector.class - [JAR]

├─ org.apache.flink.table.data.columnar.vector.heap.HeapBooleanVector.class - [JAR]

├─ org.apache.flink.table.data.columnar.vector.heap.HeapByteVector.class - [JAR]

├─ org.apache.flink.table.data.columnar.vector.heap.HeapBytesVector.class - [JAR]

├─ org.apache.flink.table.data.columnar.vector.heap.HeapDoubleVector.class - [JAR]

├─ org.apache.flink.table.data.columnar.vector.heap.HeapFloatVector.class - [JAR]

├─ org.apache.flink.table.data.columnar.vector.heap.HeapIntVector.class - [JAR]

├─ org.apache.flink.table.data.columnar.vector.heap.HeapLongVector.class - [JAR]

├─ org.apache.flink.table.data.columnar.vector.heap.HeapMapVector.class - [JAR]

├─ org.apache.flink.table.data.columnar.vector.heap.HeapRowVector.class - [JAR]

├─ org.apache.flink.table.data.columnar.vector.heap.HeapShortVector.class - [JAR]

├─ org.apache.flink.table.data.columnar.vector.heap.HeapTimestampVector.class - [JAR]

org.apache.flink.table.connector.source.abilities

├─ org.apache.flink.table.connector.source.abilities.SupportsAggregatePushDown.class - [JAR]

├─ org.apache.flink.table.connector.source.abilities.SupportsDynamicFiltering.class - [JAR]

├─ org.apache.flink.table.connector.source.abilities.SupportsFilterPushDown.class - [JAR]

├─ org.apache.flink.table.connector.source.abilities.SupportsLimitPushDown.class - [JAR]

├─ org.apache.flink.table.connector.source.abilities.SupportsPartitionPushDown.class - [JAR]

├─ org.apache.flink.table.connector.source.abilities.SupportsProjectionPushDown.class - [JAR]

├─ org.apache.flink.table.connector.source.abilities.SupportsReadingMetadata.class - [JAR]

├─ org.apache.flink.table.connector.source.abilities.SupportsRowLevelModificationScan.class - [JAR]

├─ org.apache.flink.table.connector.source.abilities.SupportsSourceWatermark.class - [JAR]

├─ org.apache.flink.table.connector.source.abilities.SupportsStatisticReport.class - [JAR]

├─ org.apache.flink.table.connector.source.abilities.SupportsWatermarkPushDown.class - [JAR]

org.apache.flink.table.sources.tsextractors

├─ org.apache.flink.table.sources.tsextractors.TimestampExtractor.class - [JAR]

├─ org.apache.flink.table.sources.tsextractors.TimestampExtractorUtils.class - [JAR]

org.apache.flink.table.api

├─ org.apache.flink.table.api.AmbiguousTableFactoryException.class - [JAR]

├─ org.apache.flink.table.api.CatalogNotExistException.class - [JAR]

├─ org.apache.flink.table.api.DataTypes.class - [JAR]

├─ org.apache.flink.table.api.ExpressionParserException.class - [JAR]

├─ org.apache.flink.table.api.JsonExistsOnError.class - [JAR]

├─ org.apache.flink.table.api.JsonOnNull.class - [JAR]

├─ org.apache.flink.table.api.JsonQueryOnEmptyOrError.class - [JAR]

├─ org.apache.flink.table.api.JsonQueryWrapper.class - [JAR]

├─ org.apache.flink.table.api.JsonType.class - [JAR]

├─ org.apache.flink.table.api.JsonValueOnEmptyOrError.class - [JAR]

├─ org.apache.flink.table.api.NoMatchingTableFactoryException.class - [JAR]

├─ org.apache.flink.table.api.Schema.class - [JAR]

├─ org.apache.flink.table.api.TableColumn.class - [JAR]

├─ org.apache.flink.table.api.TableException.class - [JAR]

├─ org.apache.flink.table.api.TableNotExistException.class - [JAR]

├─ org.apache.flink.table.api.TableSchema.class - [JAR]

├─ org.apache.flink.table.api.Types.class - [JAR]

├─ org.apache.flink.table.api.ValidationException.class - [JAR]

├─ org.apache.flink.table.api.WatermarkSpec.class - [JAR]

org.apache.flink.table.data.binary

├─ org.apache.flink.table.data.binary.BinaryArrayData.class - [JAR]

├─ org.apache.flink.table.data.binary.BinaryFormat.class - [JAR]

├─ org.apache.flink.table.data.binary.BinaryMapData.class - [JAR]

├─ org.apache.flink.table.data.binary.BinaryRawValueData.class - [JAR]

├─ org.apache.flink.table.data.binary.BinaryRowData.class - [JAR]

├─ org.apache.flink.table.data.binary.BinarySection.class - [JAR]

├─ org.apache.flink.table.data.binary.BinarySegmentUtils.class - [JAR]

├─ org.apache.flink.table.data.binary.BinaryStringData.class - [JAR]

├─ org.apache.flink.table.data.binary.LazyBinaryFormat.class - [JAR]

├─ org.apache.flink.table.data.binary.MurmurHashUtils.class - [JAR]

├─ org.apache.flink.table.data.binary.NestedRowData.class - [JAR]

├─ org.apache.flink.table.data.binary.NullAwareGetters.class - [JAR]

├─ org.apache.flink.table.data.binary.StringUtf8Utils.class - [JAR]

├─ org.apache.flink.table.data.binary.TypedSetters.class - [JAR]

org.apache.flink.table.descriptors

├─ org.apache.flink.table.descriptors.ConnectorDescriptorValidator.class - [JAR]

├─ org.apache.flink.table.descriptors.Descriptor.class - [JAR]

├─ org.apache.flink.table.descriptors.DescriptorProperties.class - [JAR]

├─ org.apache.flink.table.descriptors.DescriptorValidator.class - [JAR]

├─ org.apache.flink.table.descriptors.FileSystemValidator.class - [JAR]

├─ org.apache.flink.table.descriptors.Rowtime.class - [JAR]

├─ org.apache.flink.table.descriptors.Schema.class - [JAR]

org.apache.flink.table.sources.wmstrategies

├─ org.apache.flink.table.sources.wmstrategies.PreserveWatermarks.class - [JAR]

├─ org.apache.flink.table.sources.wmstrategies.WatermarkStrategy.class - [JAR]

org.apache.flink.table.typeutils

├─ org.apache.flink.table.typeutils.TimeIndicatorTypeInfo.class - [JAR]

├─ org.apache.flink.table.typeutils.TimeIntervalTypeInfo.class - [JAR]

org.apache.flink.table.types.inference.strategies

├─ org.apache.flink.table.types.inference.strategies.AggDecimalPlusTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.AndArgumentTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.AnyArgumentTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.ArgumentMappingTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.ArrayElementArgumentTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.ArrayTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.CastInputTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.CommonArgumentTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.CommonInputTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.CommonTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.ComparableTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.CompositeArgumentTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.ConstraintArgumentTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.CurrentWatermarkInputTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.CurrentWatermarkTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.DecimalDivideTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.DecimalModTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.DecimalPlusTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.DecimalScale0TypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.DecimalTimesTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.ExplicitArgumentTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.ExplicitTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.ExtractInputTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.FamilyArgumentTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.FirstTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.ForceNullableTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.GetTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.HiveAggDecimalPlusTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.IfNullTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.InternalReplicateRowsTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.LiteralArgumentTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.MapInputTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.MapTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.MappingTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.MatchFamilyTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.MissingTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.NullableIfArgsTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.OrArgumentTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.OrInputTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.OutputArgumentTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.RepeatingSequenceInputTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.RootArgumentTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.RoundTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.RowTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.SequenceInputTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.SourceWatermarkTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.SpecificInputTypeStrategies.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.SpecificTypeStrategies.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.StrategyUtils.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.StringConcatTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.SubsequenceInputTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.SymbolArgumentTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.TemporalOverlapsInputTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.ToTimestampLtzTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.TypeLiteralArgumentTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.UnusedTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.VaryingSequenceInputTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.VaryingStringTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.strategies.WildcardInputTypeStrategy.class - [JAR]

org.apache.flink.table.types.inference

├─ org.apache.flink.table.types.inference.ArgumentCount.class - [JAR]

├─ org.apache.flink.table.types.inference.ArgumentTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.CallContext.class - [JAR]

├─ org.apache.flink.table.types.inference.ConstantArgumentCount.class - [JAR]

├─ org.apache.flink.table.types.inference.InputTypeStrategies.class - [JAR]

├─ org.apache.flink.table.types.inference.InputTypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.Signature.class - [JAR]

├─ org.apache.flink.table.types.inference.TypeInference.class - [JAR]

├─ org.apache.flink.table.types.inference.TypeInferenceUtil.class - [JAR]

├─ org.apache.flink.table.types.inference.TypeStrategies.class - [JAR]

├─ org.apache.flink.table.types.inference.TypeStrategy.class - [JAR]

├─ org.apache.flink.table.types.inference.TypeTransformation.class - [JAR]

├─ org.apache.flink.table.types.inference.TypeTransformations.class - [JAR]

org.apache.flink.table.catalog

├─ org.apache.flink.table.catalog.AbstractCatalog.class - [JAR]

├─ org.apache.flink.table.catalog.AbstractConstraint.class - [JAR]

├─ org.apache.flink.table.catalog.Catalog.class - [JAR]

├─ org.apache.flink.table.catalog.CatalogBaseTable.class - [JAR]

├─ org.apache.flink.table.catalog.CatalogDatabase.class - [JAR]

├─ org.apache.flink.table.catalog.CatalogFunction.class - [JAR]

├─ org.apache.flink.table.catalog.CatalogLock.class - [JAR]

├─ org.apache.flink.table.catalog.CatalogPartition.class - [JAR]

├─ org.apache.flink.table.catalog.CatalogPartitionSpec.class - [JAR]

├─ org.apache.flink.table.catalog.CatalogPropertiesUtil.class - [JAR]

├─ org.apache.flink.table.catalog.CatalogTable.class - [JAR]

├─ org.apache.flink.table.catalog.CatalogView.class - [JAR]

├─ org.apache.flink.table.catalog.Column.class - [JAR]

├─ org.apache.flink.table.catalog.CommonCatalogOptions.class - [JAR]

├─ org.apache.flink.table.catalog.Constraint.class - [JAR]

├─ org.apache.flink.table.catalog.DataTypeFactory.class - [JAR]

├─ org.apache.flink.table.catalog.DefaultCatalogTable.class - [JAR]

├─ org.apache.flink.table.catalog.DefaultCatalogView.class - [JAR]

├─ org.apache.flink.table.catalog.FunctionLanguage.class - [JAR]

├─ org.apache.flink.table.catalog.ObjectIdentifier.class - [JAR]

├─ org.apache.flink.table.catalog.ObjectPath.class - [JAR]

├─ org.apache.flink.table.catalog.ResolvedCatalogBaseTable.class - [JAR]

├─ org.apache.flink.table.catalog.ResolvedCatalogTable.class - [JAR]

├─ org.apache.flink.table.catalog.ResolvedCatalogView.class - [JAR]

├─ org.apache.flink.table.catalog.ResolvedSchema.class - [JAR]

├─ org.apache.flink.table.catalog.SchemaResolver.class - [JAR]

├─ org.apache.flink.table.catalog.TableChange.class - [JAR]

├─ org.apache.flink.table.catalog.TemporaryOperationListener.class - [JAR]

├─ org.apache.flink.table.catalog.UniqueConstraint.class - [JAR]

├─ org.apache.flink.table.catalog.UnresolvedIdentifier.class - [JAR]

├─ org.apache.flink.table.catalog.WatermarkSpec.class - [JAR]

org.apache.flink.table.utils

├─ org.apache.flink.table.utils.DateTimeUtils.class - [JAR]

├─ org.apache.flink.table.utils.EncodingUtils.class - [JAR]

├─ org.apache.flink.table.utils.PartitionPathUtils.class - [JAR]

├─ org.apache.flink.table.utils.TableConnectorUtils.class - [JAR]

├─ org.apache.flink.table.utils.TableSchemaUtils.class - [JAR]

├─ org.apache.flink.table.utils.ThreadLocalCache.class - [JAR]

├─ org.apache.flink.table.utils.TypeMappingUtils.class - [JAR]

├─ org.apache.flink.table.utils.TypeStringUtils.class - [JAR]

org.apache.flink.table.resource

├─ org.apache.flink.table.resource.ResourceType.class - [JAR]

├─ org.apache.flink.table.resource.ResourceUri.class - [JAR]

org.apache.flink.table.types.utils

├─ org.apache.flink.table.types.utils.ClassDataTypeConverter.class - [JAR]

├─ org.apache.flink.table.types.utils.DataTypeDefaultVisitor.class - [JAR]

├─ org.apache.flink.table.types.utils.DataTypeUtils.class - [JAR]

├─ org.apache.flink.table.types.utils.LegacyTypeInfoDataTypeConverter.class - [JAR]

├─ org.apache.flink.table.types.utils.LogicalTypeDataTypeConverter.class - [JAR]

├─ org.apache.flink.table.types.utils.TypeConversions.class - [JAR]

├─ org.apache.flink.table.types.utils.TypeInfoDataTypeConverter.class - [JAR]

├─ org.apache.flink.table.types.utils.ValueDataTypeConverter.class - [JAR]

org.apache.flink.table.connector.source.lookup

├─ org.apache.flink.table.connector.source.lookup.AsyncLookupFunctionProvider.class - [JAR]

├─ org.apache.flink.table.connector.source.lookup.FullCachingLookupProvider.class - [JAR]

├─ org.apache.flink.table.connector.source.lookup.LookupFunctionProvider.class - [JAR]

├─ org.apache.flink.table.connector.source.lookup.LookupOptions.class - [JAR]

├─ org.apache.flink.table.connector.source.lookup.PartialCachingAsyncLookupProvider.class - [JAR]

├─ org.apache.flink.table.connector.source.lookup.PartialCachingLookupProvider.class - [JAR]

org.apache.flink.table.data.columnar

├─ org.apache.flink.table.data.columnar.ColumnarArrayData.class - [JAR]

├─ org.apache.flink.table.data.columnar.ColumnarMapData.class - [JAR]

├─ org.apache.flink.table.data.columnar.ColumnarRowData.class - [JAR]

org.apache.flink.table.sinks

├─ org.apache.flink.table.sinks.OverwritableTableSink.class - [JAR]

├─ org.apache.flink.table.sinks.PartitionableTableSink.class - [JAR]

├─ org.apache.flink.table.sinks.TableSink.class - [JAR]

├─ org.apache.flink.table.sinks.TableSinkBase.class - [JAR]

org.apache.flink.table.functions

├─ org.apache.flink.table.functions.AggregateFunction.class - [JAR]

├─ org.apache.flink.table.functions.AggregateFunctionDefinition.class - [JAR]

├─ org.apache.flink.table.functions.AsyncLookupFunction.class - [JAR]

├─ org.apache.flink.table.functions.AsyncTableFunction.class - [JAR]

├─ org.apache.flink.table.functions.BuiltInFunctionDefinition.class - [JAR]

├─ org.apache.flink.table.functions.BuiltInFunctionDefinitions.class - [JAR]

├─ org.apache.flink.table.functions.FunctionContext.class - [JAR]

├─ org.apache.flink.table.functions.FunctionDefinition.class - [JAR]

├─ org.apache.flink.table.functions.FunctionIdentifier.class - [JAR]

├─ org.apache.flink.table.functions.FunctionKind.class - [JAR]

├─ org.apache.flink.table.functions.FunctionRequirement.class - [JAR]

├─ org.apache.flink.table.functions.ImperativeAggregateFunction.class - [JAR]

├─ org.apache.flink.table.functions.LookupFunction.class - [JAR]

├─ org.apache.flink.table.functions.ScalarFunction.class - [JAR]

├─ org.apache.flink.table.functions.ScalarFunctionDefinition.class - [JAR]

├─ org.apache.flink.table.functions.SpecializedFunction.class - [JAR]

├─ org.apache.flink.table.functions.TableAggregateFunction.class - [JAR]

├─ org.apache.flink.table.functions.TableAggregateFunctionDefinition.class - [JAR]

├─ org.apache.flink.table.functions.TableFunction.class - [JAR]

├─ org.apache.flink.table.functions.TableFunctionDefinition.class - [JAR]

├─ org.apache.flink.table.functions.TemporalTableFunction.class - [JAR]

├─ org.apache.flink.table.functions.UserDefinedFunction.class - [JAR]

├─ org.apache.flink.table.functions.UserDefinedFunctionHelper.class - [JAR]

org.apache.flink.table.catalog.exceptions

├─ org.apache.flink.table.catalog.exceptions.CatalogException.class - [JAR]

├─ org.apache.flink.table.catalog.exceptions.DatabaseAlreadyExistException.class - [JAR]

├─ org.apache.flink.table.catalog.exceptions.DatabaseNotEmptyException.class - [JAR]

├─ org.apache.flink.table.catalog.exceptions.DatabaseNotExistException.class - [JAR]

├─ org.apache.flink.table.catalog.exceptions.FunctionAlreadyExistException.class - [JAR]

├─ org.apache.flink.table.catalog.exceptions.FunctionNotExistException.class - [JAR]

├─ org.apache.flink.table.catalog.exceptions.PartitionAlreadyExistsException.class - [JAR]

├─ org.apache.flink.table.catalog.exceptions.PartitionNotExistException.class - [JAR]

├─ org.apache.flink.table.catalog.exceptions.PartitionSpecInvalidException.class - [JAR]

├─ org.apache.flink.table.catalog.exceptions.TableAlreadyExistException.class - [JAR]

├─ org.apache.flink.table.catalog.exceptions.TableNotExistException.class - [JAR]

├─ org.apache.flink.table.catalog.exceptions.TableNotPartitionedException.class - [JAR]

├─ org.apache.flink.table.catalog.exceptions.TablePartitionedException.class - [JAR]

org.apache.flink.table.connector.source.lookup.cache.trigger

├─ org.apache.flink.table.connector.source.lookup.cache.trigger.CacheReloadTrigger.class - [JAR]

├─ org.apache.flink.table.connector.source.lookup.cache.trigger.PeriodicCacheReloadTrigger.class - [JAR]

├─ org.apache.flink.table.connector.source.lookup.cache.trigger.TimedCacheReloadTrigger.class - [JAR]

org.apache.flink.table.functions.python.utils

├─ org.apache.flink.table.functions.python.utils.PythonFunctionUtils.class - [JAR]

org.apache.flink.table.functions.python

├─ org.apache.flink.table.functions.python.BuiltInPythonAggregateFunction.class - [JAR]

├─ org.apache.flink.table.functions.python.PythonAggregateFunction.class - [JAR]

├─ org.apache.flink.table.functions.python.PythonAggregateFunctionInfo.class - [JAR]

├─ org.apache.flink.table.functions.python.PythonEnv.class - [JAR]

├─ org.apache.flink.table.functions.python.PythonFunction.class - [JAR]

├─ org.apache.flink.table.functions.python.PythonFunctionInfo.class - [JAR]

├─ org.apache.flink.table.functions.python.PythonFunctionKind.class - [JAR]

├─ org.apache.flink.table.functions.python.PythonScalarFunction.class - [JAR]

├─ org.apache.flink.table.functions.python.PythonTableAggregateFunction.class - [JAR]

├─ org.apache.flink.table.functions.python.PythonTableFunction.class - [JAR]

org.apache.flink.table.data.columnar.vector.writable

├─ org.apache.flink.table.data.columnar.vector.writable.AbstractWritableVector.class - [JAR]

├─ org.apache.flink.table.data.columnar.vector.writable.WritableBooleanVector.class - [JAR]

├─ org.apache.flink.table.data.columnar.vector.writable.WritableByteVector.class - [JAR]

├─ org.apache.flink.table.data.columnar.vector.writable.WritableBytesVector.class - [JAR]

├─ org.apache.flink.table.data.columnar.vector.writable.WritableColumnVector.class - [JAR]

├─ org.apache.flink.table.data.columnar.vector.writable.WritableDoubleVector.class - [JAR]

├─ org.apache.flink.table.data.columnar.vector.writable.WritableFloatVector.class - [JAR]

├─ org.apache.flink.table.data.columnar.vector.writable.WritableIntVector.class - [JAR]

├─ org.apache.flink.table.data.columnar.vector.writable.WritableLongVector.class - [JAR]

├─ org.apache.flink.table.data.columnar.vector.writable.WritableShortVector.class - [JAR]

├─ org.apache.flink.table.data.columnar.vector.writable.WritableTimestampVector.class - [JAR]

org.apache.flink.table.types.inference.transforms

├─ org.apache.flink.table.types.inference.transforms.DataTypeConversionClassTransformation.class - [JAR]

├─ org.apache.flink.table.types.inference.transforms.LegacyRawTypeTransformation.class - [JAR]

├─ org.apache.flink.table.types.inference.transforms.LegacyToNonLegacyTransformation.class - [JAR]

org.apache.flink.table.connector.source.lookup.cache

├─ org.apache.flink.table.connector.source.lookup.cache.DefaultLookupCache.class - [JAR]

├─ org.apache.flink.table.connector.source.lookup.cache.LookupCache.class - [JAR]

Advertisement

Dependencies from Group

May 19, 2023
343 usages
21.5k stars
May 19, 2023
305 usages
21.5k stars
May 19, 2023
268 usages
21.5k stars
Sep 10, 2022
224 usages

Discover Dependencies

Jun 09, 2023
209 usages
428 stars
Aug 12, 2021
194 usages
Sep 06, 2009
653 usages
Jun 15, 2022
255 usages
1.9k stars
Aug 14, 2023
257 usages
5.2k stars
May 24, 2019
174 usages
4.5k stars
api
Dec 06, 2019
178 usages
Jun 06, 2023
216 usages
4.4k stars
Feb 11, 2021
200 usages
2.6k stars
Jul 19, 2023
201 usages
2.5k stars