function createParquetShipper()

in sample/loggerSample.php [310:351]

• 37 lines of code
• 1 McCabe index (conditional complexity)

function createParquetShipper(Aliyun_Log_Client $client, $project, $logstore){
    //create shipper with json storage
    $shipper = createCommonShipper($project, $logstore, 'testparquetshipper');

    $ossParquetStorage = new Aliyun_Log_Models_OssShipperParquetStorage();
    $ossParquetStorage->setColumns(array(
        array(
            'name' => '__topic__',
            'type' => 'string'
        ),
        array(
            'name' => 'alarm_count',
            'type' => 'int32'
        ),
        array(
            'name' => 'alarm_message',
            'type' => 'string'
        ),
        array(
            'name' => 'alarm_type',
            'type' => 'string'
        ),
        array(
            'name' => 'is_active',
            'type' => 'boolean'
        ),
        array(
            'name' => 'project_name',
            'type' => 'string'
        ),
    ));
    $ossConfig = getShipperCommonConfig($ossParquetStorage);
    $shipper->setTargetConfigration($ossConfig->to_json_object());

    try{

        $client->createShipper($shipper);
    }catch (Exception $exception){
        var_dump($exception);
    }

}