Data stream Unbounded Table
new data in the
data stream
=
new rows appended
to an unbounded table
Data stream as an unbounded table
基于Scala的Apache Spark大数据处理设计源码
版权申诉
134 浏览量
2024-04-18
18:29:19
上传
评论
收藏 91.05MB ZIP 举报
基于Scala的Apache Spark大数据处理设计源码 （2000个子文件） 
spark-sql-viz.css 2KB JavaDatasetSuite.java 49KB Complex.java 36KB VectorizedColumnReader.java 32KB HiveSessionImpl.java 30KB ThriftCLIService.java 26KB WritableColumnVector.java 25KB CLIService.java 23KB UnsafeRow.java 21KB ThriftHttpServlet.java 21KB VectorizedRleValuesReader.java 21KB TableChange.java 20KB AvroOptionalPrimitives.java 19KB ThriftCLIServiceClient.java 19KB JavaDataFrameSuite.java 19KB UnsafeArrayData.java 19KB JavaBeanDeserializationSuite.java 18KB HiveAuthFactory.java 18KB AvroPrimitives.java 17KB OffHeapColumnVector.java 17KB SQLOperation.java 17KB OnHeapColumnVector.java 16KB RowBasedKeyValueBatchSuite.java 15KB RecordBinaryComparatorSuite.java 14KB ArrowColumnVector.java 13KB SessionManager.java 13KB SpecificParquetRecordReaderBase.java 13KB JavaSQLDataSourceExample.java 13KB UnsafeKVExternalSorter.java 12KB VectorizedParquetRecordReader.java 12KB ParquetAvroCompat.java 12KB Operation.java 11KB ColumnVector.java 11KB OperationManager.java 11KB JavaSparkSQLExample.java 11KB GetColumnsOperation.java 11KB JavaStructuredSessionization.java 9KB HiveServer2.java 9KB MutableColumnarRow.java 9KB UnsafeExternalRowSorter.java 9KB ColumnarBatch.java 9KB VectorizedPlainValuesReader.java 9KB ColumnValue.java 9KB ColumnVectorUtils.java 9KB UnsafeFixedWidthAggregationMap.java 9KB AvroNonNullableArrays.java 8KB JavaRandomRDDsSuite.java 8KB ThriftHttpCLIService.java 8KB TableCatalog.java 8KB XXH64Suite.java 8KB Nested.java 8KB JavaHigherOrderFunctionsSuite.java 8KB LogDivertAppender.java 8KB StagingTableCatalog.java 8KB CatalogLoadingSuite.java 8KB OrcColumnarBatchReader.java 8KB JavaRecoverableNetworkWordCount.java 8KB HiveSQLException.java 8KB HttpAuthUtils.java 7KB HiveCommandOperation.java 7KB GetCrossReferenceOperation.java 7KB UnsafeWriter.java 7KB JavaApplySchemaSuite.java 7KB RowBasedKeyValueBatch.java 7KB JavaLDASuite.java 7KB JavaRowSuite.java 7KB UnsafeRowWriter.java 7KB DataTypes.java 7KB JavaALSSuite.java 7KB ColumnarRow.java 7KB UDFXPathUtil.java 7KB XXH64.java 6KB AvroMapOfArray.java 6KB VariableLengthRowBasedKeyValueBatch.java 6KB AvroArrayOfArray.java 6KB JavaLogisticRegressionSuite.java 6KB ExpressionInfo.java 6KB JavaDirectKerberizedKafkaWordCount.java 6KB HiveSessionImplwithUGI.java 6KB UnsafeArrayWriter.java 6KB SupportsNamespaces.java 6KB UnsafeMapData.java 6KB ThriftBinaryCLIService.java 6KB OrcColumnVector.java 6KB PlainSaslServer.java 6KB CaseInsensitiveStringMap.java 6KB JavaMatricesSuite.java 6KB GetFunctionsOperation.java 6KB ParquetEnum.java 6KB ColumnBasedSet.java 6KB GetTablesOperation.java 6KB ColumnarArray.java 6KB HiveSession.java 6KB JavaRankingMetricsExample.java 6KB PlainSaslHelper.java 6KB FixedLengthRowBasedKeyValueBatch.java 6KB JavaAdvancedDataSourceV2.java 6KB GetTypeInfoOperation.java 6KB Expressions.java 5KB JavaStructuredKerberizedKafkaWordCount.java 5KB共 2000 条
- 1
- 2
- 3
- 4
- 5
- 6
- 20
资源评论
