Example 1: Static File in AVRO Format
DATASTORE gs://mybucket/employee.dat
OF AVRO
AS TARGET
DESCRIBED BY GROUP SOURCE;Example 2: Rotated Files in JSON Format
DATASTORE gs://mybucket/cdcdata
OF JSON
AS TARGET
DESCRIBED BY GROUP SOURCE
STAGING SIZE 4G
STAGING DELAY 120;