tonyyang-svail

import (
  	"encoding/json"
	"fmt"
)

func JSONPrint(i interface{}) {
	b, err := json.MarshalIndent(i, "", "  ")
	if err != nil {
		fmt.Println("error:", err)
	}

tonyyang-svail

title

@tonyyang-svail

tonyyang-svail

tonyyang-svail

syntax = "proto3";

import "google/protobuf/any.proto";

package server;

// SQL statements like `SELECT ...`, `DESCRIBE ...` returns a rowset.
// The rowset might be big. In such cases, Query returns a stream
// of RunResponse
//

tonyyang-svail

syntax = "proto3";

import "google/protobuf/any.proto";

package server;

service SQLFlow {
  rpc File (Request) returns (Job);
  rpc ReadRow(Job) returns (stream Row);
  rpc ReadLog(Job) returns (stream Log);

tonyyang-svail

syntax = "proto3";

import "google/protobuf/any.proto";

package server;

service SQLFlow {
  rpc Query (Request) returns (stream RowSet);
  rpc Execute (Request) returns (stream Messages);
}

tonyyang-svail

syntax = "proto3";

import "google/protobuf/any.proto";

package server;

service SQLFlow {
  rpc Query (Request) returns (stream RowSet);
  rpc Execute (Request) returns (stream Messages);
}

tonyyang-svail

package main

import (
	"fmt"

	"github.com/pkg/errors"
)

func bar() error {
	return errors.Wrap(fmt.Errorf("barError"), "bar")

tonyyang-svail

:= is similar to var =

Setting GOPATH

export GOPATH=~/go
export PATH=$PATH:$GOPATH/bin

:= slice is shallow copy

tonyyang-svail

Flink