diff --git a/src/datapage.js b/src/datapage.js index a3eb672..4613b22 100644 --- a/src/datapage.js +++ b/src/datapage.js @@ -193,7 +193,7 @@ export function assembleObjects( const assign = [] for (let counter = 0; counter < repetitionLevels.length; counter++) { - const def = definitionLevels ? definitionLevels[counter] : maxDefinitionLevel + const def = definitionLevels?.length ? definitionLevels[counter] : maxDefinitionLevel const rep = repetitionLevels[counter] if (!rep) { diff --git a/test/files/nonnullable.impala.json b/test/files/nonnullable.impala.json index 9e8379d..1b4f003 100644 --- a/test/files/nonnullable.impala.json +++ b/test/files/nonnullable.impala.json @@ -1,31 +1,14 @@ [ [ 8, - [], - [ - -1, - -2, - null - ], - [], - [], - [ - null, - "k1", - null, - null - ], - [ - null, - 1, - null, - null - ], + [-1], + [-1, -2, null], + { "k1": -1 }, + { "k1": 1 }, -1, - [], - [], - [], - [], + [-1], + [-1], + ["nonnullable"], [] ] ] diff --git a/test/read.test.js b/test/read.test.js index fe10a25..5e5bd05 100644 --- a/test/read.test.js +++ b/test/read.test.js @@ -17,7 +17,7 @@ const compressors = { } describe('parquetRead', () => { - const files = fs.readdirSync('test/files').filter(f => f.endsWith('Int_Map.parquet')) + const files = fs.readdirSync('test/files').filter(f => f.endsWith('.parquet')) files.forEach(file => { it(`should parse data from ${file}`, async () => {