PLATFORMS SOLUTIONS BLOGS CONTACT ☰

Parquet Adapter



Provides read/write access to Parquet files using SQL Server and REST commands.


Want to try it in Azure? Click here to learn more or click here to create a new Enzo Server RTM 3.1 Azure VM now.
Want to try it in AWS? Click here to learn more or click here to create a new Enzo Server RTM 3.1 AWS VM now.


Configuration Settings



Name Description Default
Boolean _isDefault Make this the default configuration. Defaults to true if configName is already the default.
String defaultFilePath The default file name to use (full path)
String schemaFile The file used to specify the default schema for Parquet files

Handlers



readHeaders
headers 		Read headers from a parquet file details 

Arguments

Name Description Default
fileName The file name or path is used to get files
topn TOP N records will be returned (used with EXEC operation)

SQL Call

exec Parquet.readHeaders
SELECT * FROM Parquet.headers


Http Call

/parquet/readheaders

Output Columns

String name
String path
String dataType
Boolean hasNulls
String schemaType
readRows
rows 		Read one or more Parquet files in parallel details 

Arguments

Name Description Default
definitionName Name of previously stored definition. Can include a secondary definition name when using protocol adapters (like FTP): config,secondaryconfig
fileName The file name or path used to get files (wildcards are accepted for local files, Azure Blobs, AWS Buckets, and FTP files)
schemaFile The file name to use to obtain the schema (leave blank to use defaultSchema setting)
topn TOP N records will be returned (used with EXEC operation)

SQL Call

exec Parquet.readRows
select * from Parquet.rows


Http Call

/parquet/readrows

Output Columns

This call does not return data.

writeFile
Write a Parquet file details 

Arguments

Name Description Default
sourceConnection R The source connection string (or Central Connection String name)
sqlread R The source SQL Statement that extracts data from the source system
fileName Full path of the file. If empty, a TMP file will be created
overwrite When 1, override the destination file False
sourceTimeout The source timeout is used to specifed the query timeout 0

SQL Call

exec Parquet.writeFile 'EnzoLoopBack', 'select Top 100 * from Table1', 'D:\test001.parquet'


Http Call

/parquet/writefile

Output Columns

Int64 rowCount
Double elapsedSec
String fileName







601 21st St Suite 300
Vero Beach, FL 32960
United States

(561) 921-8669
info@enzounified.com
terms of service
privacy policy

PLATFORM

ENZO SERVER
ENZO DATAZEN

SOLUTIONS

SOLUTIONS OVERVIEW
INTEGRATION
SaaS
CLOUD ANALYTICS

RESOURCES

DOWNLOAD
BLOGS & VIDEOS
IN THE NEWS
ENZO ADAPTERS
ONLINE DOCUMENTATION
TCO CALCULATOR

COMPANY

LEADERSHIP TEAM
PARTNERS


© 2023 - Enzo Unified