/dports/devel/spark/spark-2.1.1/sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/ |
H A D | RowBasedKeyValueBatch.java | 54 protected final StructType valueSchema; field in RowBasedKeyValueBatch 70 public static RowBasedKeyValueBatch allocate(StructType keySchema, StructType valueSchema, in allocate() argument 72 return allocate(keySchema, valueSchema, manager, DEFAULT_CAPACITY); in allocate() 75 public static RowBasedKeyValueBatch allocate(StructType keySchema, StructType valueSchema, in allocate() argument 84 for (String name : valueSchema.fieldNames()) { in allocate() 86 && UnsafeRow.isFixedLength(valueSchema.apply(name).dataType()); in allocate() 90 return new FixedLengthRowBasedKeyValueBatch(keySchema, valueSchema, maxRows, manager); in allocate() 92 return new VariableLengthRowBasedKeyValueBatch(keySchema, valueSchema, maxRows, manager); in allocate() 96 protected RowBasedKeyValueBatch(StructType keySchema, StructType valueSchema, int maxRows, in RowBasedKeyValueBatch() argument 101 this.valueSchema = valueSchema; in RowBasedKeyValueBatch() [all …]
|
H A D | FixedLengthRowBasedKeyValueBatch.java | 109 private final UnsafeRow value = new UnsafeRow(valueSchema.length()); in rowIterator() 165 protected FixedLengthRowBasedKeyValueBatch(StructType keySchema, StructType valueSchema, in FixedLengthRowBasedKeyValueBatch() argument 167 super(keySchema, valueSchema, maxRows, manager); in FixedLengthRowBasedKeyValueBatch() 169 int valueSize = valueSchema.size() * 8; in FixedLengthRowBasedKeyValueBatch() 171 vlen = valueSize + UnsafeRow.calculateBitSetWidthInBytes(valueSchema.length()); in FixedLengthRowBasedKeyValueBatch()
|
H A D | VariableLengthRowBasedKeyValueBatch.java | 116 private final UnsafeRow value = new UnsafeRow(valueSchema.length()); in rowIterator() 180 protected VariableLengthRowBasedKeyValueBatch(StructType keySchema, StructType valueSchema, in VariableLengthRowBasedKeyValueBatch() argument 182 super(keySchema, valueSchema, maxRows, manager); in VariableLengthRowBasedKeyValueBatch()
|
/dports/devel/spark/spark-2.1.1/sql/core/src/test/scala/org/apache/spark/sql/execution/ |
H A D | UnsafeKVExternalSorterSuite.scala | 47 val valueSchema = RandomDataGenerator.randomSchema(rand, rand.nextInt(10) + 1, valueTypes) constant 48 testKVSorter(keySchema, valueSchema, spill = i > 3) 65 private def testKVSorter(keySchema: StructType, valueSchema: StructType, spill: Boolean): Unit = { 68 val vExternalConverter = CatalystTypeConverters.createToCatalystConverter(valueSchema) 70 val vConverter = UnsafeProjection.create(valueSchema) 73 val valueDataGen = RandomDataGenerator.forType(valueSchema, nullable = false).get 82 val valueSchemaStr = valueSchema.map(_.dataType.simpleString).mkString("[", ",", "]") 87 valueSchema, 110 valueSchema: StructType, 127 keySchema, valueSchema, SparkEnv.get.blockManager, SparkEnv.get.serializerManager, [all …]
|
/dports/devel/spark/spark-2.1.1/sql/core/src/test/scala/org/apache/spark/sql/execution/streaming/state/ |
H A D | StateStoreRDDSuite.scala | 44 private val valueSchema = StructType(Seq(StructField("value", IntegerType, true))) 63 spark.sqlContext, path, opId, storeVersion = 0, keySchema, valueSchema)( 69 spark.sqlContext, path, opId, storeVersion = 1, keySchema, valueSchema)(increment) 87 sqlContext, path, opId, storeVersion, keySchema, valueSchema)(increment) 134 spark.sqlContext, path, opId, storeVersion = 0, keySchema, valueSchema)(iteratorOfGets) 138 sqlContext, path, opId, storeVersion = 0, keySchema, valueSchema)(iteratorOfPuts) 142 sqlContext, path, opId, storeVersion = 1, keySchema, valueSchema)(iteratorOfGets) 163 sqlContext, path, opId, storeVersion = 0, keySchema, valueSchema)(increment) 190 sqlContext, path, opId, storeVersion = 0, keySchema, valueSchema)(increment) 195 sqlContext, path, opId, storeVersion = 1, keySchema, valueSchema)(increment)
|
H A D | StateStoreSuite.scala | 51 private val valueSchema = StructType(Seq(StructField("value", IntegerType, true))) 114 store.id, keySchema, valueSchema, StateStoreConf.empty, new Configuration) 347 StateStore.get(storeId, keySchema, valueSchema, -1, storeConf, hadoopConf) 352 StateStore.get(storeId, keySchema, valueSchema, 1, storeConf, hadoopConf) 356 val store0 = StateStore.get(storeId, keySchema, valueSchema, 0, storeConf, hadoopConf) 393 storeId, keySchema, valueSchema, storeConf, hadoopConf) 400 storeId, keySchema, valueSchema, latestStoreVersion, storeConf, hadoopConf) 512 StateStore.get(storeId, keySchema, valueSchema, 0, storeConf, hadoopConf) 527 StateStore.get(storeId, keySchema, valueSchema, 1, storeConf, hadoopConf) 540 StateStore.get(storeId, keySchema, valueSchema, 2, storeConf, hadoopConf) [all …]
|
/dports/devel/spark/spark-2.1.1/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/ |
H A D | package.scala | 38 valueSchema: StructType)( 46 valueSchema, 58 valueSchema: StructType, 70 valueSchema,
|
H A D | StateStoreRDD.scala | 40 valueSchema: StructType, 62 storeId, keySchema, valueSchema, storeVersion, storeConf, confBroadcast.value.value)
|
H A D | StateStore.scala | 173 valueSchema: StructType, 182 new HDFSBackedStateStoreProvider(storeId, keySchema, valueSchema, storeConf, hadoopConf))
|
/dports/devel/spark/spark-2.1.1/sql/core/src/main/java/org/apache/spark/sql/execution/ |
H A D | UnsafeKVExternalSorter.java | 49 private final StructType valueSchema; field in UnsafeKVExternalSorter 55 StructType valueSchema, in UnsafeKVExternalSorter() argument 60 this(keySchema, valueSchema, blockManager, serializerManager, pageSizeBytes, in UnsafeKVExternalSorter() 66 StructType valueSchema, in UnsafeKVExternalSorter() argument 73 this.valueSchema = valueSchema; in UnsafeKVExternalSorter() 249 private UnsafeRow value = new UnsafeRow(valueSchema.size());
|
/dports/devel/spark/spark-2.1.1/sql/catalyst/src/test/java/org/apache/spark/sql/catalyst/expressions/ |
H A D | RowBasedKeyValueBatchSuite.java | 137 valueSchema, taskMemoryManager, DEFAULT_CAPACITY); in emptyBatch() 173 valueSchema, taskMemoryManager, DEFAULT_CAPACITY); in batchType() 175 valueSchema, taskMemoryManager, DEFAULT_CAPACITY); in batchType() 188 valueSchema, taskMemoryManager, DEFAULT_CAPACITY); in setAndRetrieve() 225 valueSchema, taskMemoryManager, DEFAULT_CAPACITY); in setUpdateAndRetrieve() 242 valueSchema, taskMemoryManager, DEFAULT_CAPACITY); in iteratorTest() 274 valueSchema, taskMemoryManager, DEFAULT_CAPACITY); in fixedLengthTest() 314 valueSchema, taskMemoryManager, 10); in appendRowUntilExceedingCapacity() 344 valueSchema, taskMemoryManager, pageSizeToUse); //enough capacity in appendRowUntilExceedingPageSize() 378 valueSchema, taskMemoryManager, DEFAULT_CAPACITY); in failureToAllocateFirstPage() [all …]
|
/dports/textproc/kibana7/kibana-7.16.2-darwin-x86_64/node_modules/@kbn/config-schema/ |
H A D | README.md | 65 const valueSchema = schema.object({ 138 const valueSchema = schema.number({ max: 10 }); 174 const valueSchema = [ 246 const valueSchema = schema.object({ 327 const valueSchema = schema.any(); 369 const valueSchema = schema.never(); 455 const valueSchema = schema.object({ 474 const valueSchema = schema.object({ 477 valueSchema.validate({}, { envName: 'dev' }); 492 const valueSchema = schema.object({ [all …]
|
/dports/textproc/opensearch-dashboards/opensearch-dashboards-1.2.0-linux-x64/node_modules/@osd/config-schema/ |
H A D | README.md | 65 const valueSchema = schema.object({ 138 const valueSchema = schema.number({ max: 10 }); 174 const valueSchema = [ 246 const valueSchema = schema.object({ 327 const valueSchema = schema.any(); 369 const valueSchema = schema.never(); 455 const valueSchema = schema.object({ 474 const valueSchema = schema.object({ 477 valueSchema.validate({}, { envName: 'dev' }); 492 const valueSchema = schema.object({ [all …]
|
/dports/www/gohugo/hugo-0.91.2/vendor/github.com/getkin/kin-openapi/openapi3filter/ |
H A D | req_resp_decoder.go | 957 var valueSchema *openapi3.SchemaRef 959 valueSchema, exists = schema.Value.Properties[name] 975 valueSchema, exists = schema.Value.AdditionalProperties.Value.Properties[name] 980 if valueSchema.Value.Type == "array" { 981 valueSchema = valueSchema.Value.Items 985 if value, err = decodeBody(part, http.Header(part.Header), valueSchema, subEncFn); err != nil {
|
/dports/devel/upp/upp/bazaar/plugin/assimp/contrib/rapidjson/include/rapidjson/ |
H A D | schema.h | 276 valueSchema(), in SchemaValidationContext() 315 const SchemaType* valueSchema; member 605 context.valueSchema = itemsList_; in BeginValue() 612 context.valueSchema = typeless_; in BeginValue() 617 context.valueSchema = typeless_; in BeginValue() 788 context.valueSchema = typeless_; in Key() 796 context.valueSchema = typeless_; in Key() 811 context.valueSchema = typeless_; in Key() 819 context.valueSchema = typeless_; in Key() 1841 RAPIDJSON_ASSERT(CurrentContext().valueSchema); [all …]
|
/dports/graphics/qt5-3d/kde-qt3d-5.15.2p39/src/3rdparty/assimp/contrib/rapidjson/include/rapidjson/ |
H A D | schema.h | 276 valueSchema(), in SchemaValidationContext() 315 const SchemaType* valueSchema; member 605 context.valueSchema = itemsList_; in BeginValue() 612 context.valueSchema = typeless_; in BeginValue() 617 context.valueSchema = typeless_; in BeginValue() 788 context.valueSchema = typeless_; in Key() 796 context.valueSchema = typeless_; in Key() 811 context.valueSchema = typeless_; in Key() 819 context.valueSchema = typeless_; in Key() 1841 RAPIDJSON_ASSERT(CurrentContext().valueSchema); [all …]
|
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/linkedin/goavro/v2/ |
H A D | map.go | 22 valueSchema, ok := schemaMap["values"] 26 valueCodec, err := buildCodec(st, namespace, valueSchema)
|
/dports/games/keeperrl/keeperrl-alpha23/extern/cereal/external/rapidjson/ |
H A D | schema.h | 276 valueSchema(), in SchemaValidationContext() 315 const SchemaType* valueSchema; member 606 context.valueSchema = itemsList_; in BeginValue() 613 context.valueSchema = GetTypeless(); in BeginValue() 618 context.valueSchema = GetTypeless(); in BeginValue() 795 context.valueSchema = GetTypeless(); in Key() 799 context.valueSchema = properties_[index].schema; in Key() 810 context.valueSchema = GetTypeless(); in Key() 818 context.valueSchema = GetTypeless(); in Key() 1826 if (CurrentContext().valueSchema) [all …]
|
/dports/games/jaggedalliance2/ja2-stracciatella-0.18.0/dependencies/lib-rapidjson/rapidjson-1.1.0/include/rapidjson/ |
H A D | schema.h | 276 valueSchema(), in SchemaValidationContext() 315 const SchemaType* valueSchema; member 606 context.valueSchema = itemsList_; in BeginValue() 613 context.valueSchema = GetTypeless(); in BeginValue() 618 context.valueSchema = GetTypeless(); in BeginValue() 795 context.valueSchema = GetTypeless(); in Key() 799 context.valueSchema = properties_[index].schema; in Key() 810 context.valueSchema = GetTypeless(); in Key() 818 context.valueSchema = GetTypeless(); in Key() 1826 if (CurrentContext().valueSchema) [all …]
|
/dports/emulators/mess/mame-mame0226/3rdparty/rapidjson/include/rapidjson/ |
H A D | schema.h | 276 valueSchema(), in SchemaValidationContext() 315 const SchemaType* valueSchema; member 606 context.valueSchema = itemsList_; in BeginValue() 613 context.valueSchema = GetTypeless(); in BeginValue() 618 context.valueSchema = GetTypeless(); in BeginValue() 795 context.valueSchema = GetTypeless(); in Key() 799 context.valueSchema = properties_[index].schema; in Key() 810 context.valueSchema = GetTypeless(); in Key() 818 context.valueSchema = GetTypeless(); in Key() 1826 if (CurrentContext().valueSchema) [all …]
|
/dports/games/fs2open/fs2open.github.com-release_21_4_1/lib/discord/thirdparty/rapidjson/ |
H A D | schema.h | 276 valueSchema(), in SchemaValidationContext() 315 const SchemaType* valueSchema; member 606 context.valueSchema = itemsList_; in BeginValue() 613 context.valueSchema = GetTypeless(); in BeginValue() 618 context.valueSchema = GetTypeless(); in BeginValue() 795 context.valueSchema = GetTypeless(); in Key() 799 context.valueSchema = properties_[index].schema; in Key() 810 context.valueSchema = GetTypeless(); in Key() 818 context.valueSchema = GetTypeless(); in Key() 1826 if (CurrentContext().valueSchema) [all …]
|
/dports/math/e-antic/cereal-51cbda5/include/cereal/external/rapidjson/ |
H A D | schema.h | 276 valueSchema(), in SchemaValidationContext() 315 const SchemaType* valueSchema; member 606 context.valueSchema = itemsList_; in BeginValue() 613 context.valueSchema = GetTypeless(); in BeginValue() 618 context.valueSchema = GetTypeless(); in BeginValue() 795 context.valueSchema = GetTypeless(); in Key() 799 context.valueSchema = properties_[index].schema; in Key() 810 context.valueSchema = GetTypeless(); in Key() 818 context.valueSchema = GetTypeless(); in Key() 1826 if (CurrentContext().valueSchema) [all …]
|
/dports/converters/osm2pgsql/osm2pgsql-1.5.1/contrib/rapidjson/include/rapidjson/ |
H A D | schema.h | 276 valueSchema(), in SchemaValidationContext() 315 const SchemaType* valueSchema; member 606 context.valueSchema = itemsList_; in BeginValue() 613 context.valueSchema = GetTypeless(); in BeginValue() 618 context.valueSchema = GetTypeless(); in BeginValue() 795 context.valueSchema = GetTypeless(); in Key() 799 context.valueSchema = properties_[index].schema; in Key() 810 context.valueSchema = GetTypeless(); in Key() 818 context.valueSchema = GetTypeless(); in Key() 1826 if (CurrentContext().valueSchema) [all …]
|
/dports/games/supertux2/SuperTux-v0.6.3-Source/external/discord-sdk/thirdparty/rapidjson-1.1.0/include/rapidjson/ |
H A D | schema.h | 276 valueSchema(), in SchemaValidationContext() 315 const SchemaType* valueSchema; member 606 context.valueSchema = itemsList_; in BeginValue() 613 context.valueSchema = GetTypeless(); in BeginValue() 618 context.valueSchema = GetTypeless(); in BeginValue() 795 context.valueSchema = GetTypeless(); in Key() 799 context.valueSchema = properties_[index].schema; in Key() 810 context.valueSchema = GetTypeless(); in Key() 818 context.valueSchema = GetTypeless(); in Key() 1826 if (CurrentContext().valueSchema) [all …]
|
/dports/misc/usd/USD-21.11/pxr/base/js/rapidjson/ |
H A D | schema.h | 277 valueSchema(), in SchemaValidationContext() 316 const SchemaType* valueSchema; member 604 context.valueSchema = itemsList_; in BeginValue() 611 context.valueSchema = GetTypeless(); in BeginValue() 616 context.valueSchema = GetTypeless(); in BeginValue() 794 context.valueSchema = GetTypeless(); in Key() 798 context.valueSchema = properties_[index].schema; in Key() 812 context.valueSchema = GetTypeless(); in Key() 820 context.valueSchema = GetTypeless(); in Key() 1821 if (CurrentContext().valueSchema) [all …]
|