Home
last modified time | relevance | path

Searched refs:valueSchema (Results 1 – 25 of 65) sorted by relevance

123

/dports/devel/spark/spark-2.1.1/sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/
H A DRowBasedKeyValueBatch.java54 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 DFixedLengthRowBasedKeyValueBatch.java109 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 DVariableLengthRowBasedKeyValueBatch.java116 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 DUnsafeKVExternalSorterSuite.scala47 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 DStateStoreRDDSuite.scala44 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 DStateStoreSuite.scala51 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 Dpackage.scala38 valueSchema: StructType)(
46 valueSchema,
58 valueSchema: StructType,
70 valueSchema,
H A DStateStoreRDD.scala40 valueSchema: StructType,
62 storeId, keySchema, valueSchema, storeVersion, storeConf, confBroadcast.value.value)
H A DStateStore.scala173 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 DUnsafeKVExternalSorter.java49 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 DRowBasedKeyValueBatchSuite.java137 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 DREADME.md65 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 DREADME.md65 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 Dreq_resp_decoder.go957 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 Dschema.h276 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 Dschema.h276 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 Dmap.go22 valueSchema, ok := schemaMap["values"]
26 valueCodec, err := buildCodec(st, namespace, valueSchema)
/dports/games/keeperrl/keeperrl-alpha23/extern/cereal/external/rapidjson/
H A Dschema.h276 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 Dschema.h276 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 Dschema.h276 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 Dschema.h276 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 Dschema.h276 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 Dschema.h276 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 Dschema.h276 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 Dschema.h277 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 …]

123