Radio
DMR
Cyfrowe radio - https://en.wikipedia.org/wiki/Digital_mobile_radio
create table weather (longitude double not null, | |
latitude double not null, | |
time_ timestamp not null, | |
u10 double not null, | |
v10 double not null, | |
snow_density float not null, | |
snow_depth float not null, | |
snowfall float not null, | |
snowc double not null, | |
smlt double not null, |
Cyfrowe radio - https://en.wikipedia.org/wiki/Digital_mobile_radio
package main | |
import ( | |
"context" | |
"net/http" | |
) | |
func checkErr(err error) { | |
if err != nil { | |
panic(err) |
go test -test.v -test.bench ^BenchmarkSearch_Search.*$ -test.run ^$ | |
goos: linux | |
goarch: amd64 | |
pkg: github.com/datainq/teryt/search | |
BenchmarkSearch_SearchOld | |
BenchmarkSearch_SearchOld-8 37 33642952 ns/op | |
BenchmarkSearch_Search | |
BenchmarkSearch_Search-8 152 7784588 ns/op | |
BenchmarkSearch_SearchV3 | |
BenchmarkSearch_SearchV3/parallel-1 |
Old levenstein:
/tmp/___gobench_github_com_datainq_teryt_search -test.v -test.bench . -test.run ^$
goos: linux
goarch: amd64
pkg: github.com/datainq/teryt/search
BenchmarkSearch_SearchOld
BenchmarkSearch_SearchOld-8 31 40371148 ns/op
BenchmarkSearch_Search
package main | |
import ( | |
"bytes" | |
"encoding/json" | |
"flag" | |
"fmt" | |
"io/ioutil" | |
"os" | |
) |
package eu.datainq.playground; | |
import org.apache.beam.sdk.coders.VarIntCoder; | |
import org.apache.beam.sdk.testing.NeedsRunner; | |
import org.apache.beam.sdk.testing.PAssert; | |
import org.apache.beam.sdk.testing.TestPipeline; | |
import org.apache.beam.sdk.testing.TestStream; | |
import org.apache.beam.sdk.transforms.Create; | |
import org.apache.beam.sdk.transforms.Sum; | |
import org.apache.beam.sdk.transforms.WithKeys; |
package main | |
import ( | |
"context" | |
"fmt" | |
"log" | |
"net/http" | |
"time" | |
) |
//!! Processing provides [] from input tools/closure-compiler/externs/browser/w3c_eventsource.js | |
//!! Processing provides [goog.labs.userAgent.engine] from input closure-library/closure/goog/labs/useragent/engine.js | |
//!! Processing provides [goog.html.TrustedResourceUrl] from input closure-library/closure/goog/html/trustedresourceurl.js | |
//!! Processing provides [goog.events.EventId] from input closure-library/closure/goog/events/eventid.js | |
//!! Processing provides [goog.html.SafeUrl] from input closure-library/closure/goog/html/safeurl.js | |
//!! Processing provides [] from input tools/closure-compiler/externs/browser/intl.js | |
//!! Processing provides [] from input tools/closure-compiler/externs/browser/w3c_pointerlock.js | |
//!! Processing provides [goog.dom.vendor] from input closure-library/closure/goog/dom/vendor.js | |
//!! Processing provides [] from input tools/closure-compiler/externs/browser/w3c_vibration.js | |
//!! Processing provides [] from input tools/closure-compiler/externs/browser/webkit_notifications.js |
func (p *XImpl) Listen(_ *empty.Empty, rec services.X_ListenServer) error { | |
c := make(chan *services.X, 16) | |
p.add(c) | |
defer p.remove(c) | |
ctx := rec.Context() | |
for { | |
select { | |
case v := <-c: | |
if err := rec.Send(v); err != nil { | |
return err |