def log_to_parquet(bro_log, parquet_file, compression='SNAPPY', row_group_size=1000000):
    """write_to_parquet: Converts a Bro log into a Parquet file
        Args:
            bro_log (string: The full path to the bro log to be saved as a Parquet file
            parquet_file (string): The full path to the filename for the Parquet file
            compression (string): The compression algo to use (defaults to 'SNAPPY')
            row_group_size (int): The size of the parquet row groups (defaults to 1000000)
        Notes:
            Right now there are two open Parquet issues
            - Timestamps in Spark: https://issues.apache.org/jira/browse/ARROW-1499
            - TimeDelta Support: https://issues.apache.org/jira/browse/ARROW-835
    """

    # Set up various parameters
    current_row_set = []
    writer = None
    num_rows = 0

    # Spin up the bro reader on a given log file
    reader = BroLogReader(bro_log)
    for num_rows, row in enumerate(reader.readrows()):

        # Append the row to the row set
        current_row_set.append(row)

        # If we have enough rows add to the Parquet table
        if num_rows % row_group_size == 0:
            print('Writing {:d} rows...'.format(num_rows))
            if writer is None:
                arrow_table = pa.Table.from_pandas(_make_df(current_row_set))
                writer = pq.ParquetWriter(parquet_file, arrow_table.schema, compression=compression, use_deprecated_int96_timestamps=True)
                writer.write_table(arrow_table)
            else:
                arrow_table = pa.Table.from_pandas(_make_df(current_row_set))
                writer.write_table(arrow_table)

            # Empty the current row set
            current_row_set = []

    # Add any left over rows and close the Parquet file
    if num_rows:
        print('Writing {:d} rows...'.format(num_rows))
        arrow_table = pa.Table.from_pandas(_make_df(current_row_set))
        writer.write_table(arrow_table)
        writer.close()
        print('Parquet File Complete')
write_to_parquet: Converts a Bro log into a Parquet file
        Args:
            bro_log (string: The full path to the bro log to be saved as a Parquet file
            parquet_file (string): The full path to the filename for the Parquet file
            compression (string): The compression algo to use (defaults to 'SNAPPY')
            row_group_size (int): The size of the parquet row groups (defaults to 1000000)
        Notes:
            Right now there are two open Parquet issues
            - Timestamps in Spark: https://issues.apache.org/jira/browse/ARROW-1499
            - TimeDelta Support: https://issues.apache.org/jira/browse/ARROW-835