gudusoft.gsqlparser.common.structured.adapters

Class SparkFromJsonExplodeAdapter

Object

gudusoft.gsqlparser.common.structured.adapters.SparkFromJsonExplodeAdapter

All Implemented Interfaces:

StructuredDataflowAdapter

public final class SparkFromJsonExplodeAdapter
extends Object
implements StructuredDataflowAdapter

Recognizes the Spark SQL pattern explode(from_json(<column>, '<literal ARRAY<STRUCT<...>> schema>')) (also explode_outer) and produces a vendor-neutral StructuredDataflowDescriptor. Unsupported variants (dynamic schema column, schema_of_json(...), MAP element fields, posexplode, inline, etc.) return null so the existing generic function lineage runs unchanged.

The same syntactic pattern is supported by Hive (which shares Spark's from_json + explode UDFs and ARRAY/STRUCT type-string grammar), so the adapter also matches EDbVendor.dbvhive.

Constructor Summary

Constructors

Constructor and Description
SparkFromJsonExplodeAdapter()

Method Summary

Modifier and Type	Method and Description
StructuredDataflowDescriptor	describe(TParseTreeNode node, StructuredAdapterContext context)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SparkFromJsonExplodeAdapter

public SparkFromJsonExplodeAdapter()

Method Detail

describe

public StructuredDataflowDescriptor describe(TParseTreeNode node,
                                             StructuredAdapterContext context)

Specified by:

describe in interface StructuredDataflowAdapter

Returns:

descriptor if the adapter recognizes the pattern, else null.