Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- SCHEMA = StructType([
- StructField('Foo', StringType()),
- StructField('TimeA', StructType([
- StructField('__encode__', StringType()),
- StructField('value', DoubleType()),
- ]), metadata={'encoding': 'timestamp'}),
- StructField('ListOfItems', ArrayType(StructType([
- StructField('Bar', StringType()),
- StructField('Item', StructType([
- StructField('TimeB', StructType([
- StructField('__encode__', StringType()),
- StructField('value', DoubleType()),
- ]), metadata={'encoding': 'timestamp'}),
- StructField('Baz', StringType()),
- ])),
- ]))),
- StructField('ComplexStruct', StructType([
- StructField('ComplexLevel1', StructType([
- StructField('TimeC', StructType([
- StructField('__encode__', StringType()),
- StructField('value', DoubleType()),
- ]), metadata={'encoding': 'timestamp'}),
- StructField('Field', StringType()),
- StructField('ComplexLevel2', StructType([
- StructField('TimeD', StructType([
- StructField('__encode__', StringType()),
- StructField('value', DoubleType()),
- ]), metadata={'encoding': 'timestamp'}),
- ])),
- StructField('Foo', IntegerType()),
- ])),
- ])),
- ])
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement