-
-
Notifications
You must be signed in to change notification settings - Fork 3
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge branch 'main' into dep_replace
- Loading branch information
Showing
104 changed files
with
13,330 additions
and
12 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,45 @@ | ||
| # Simple workflow for deploying static content to GitHub Pages | ||
| name: Deploy Flux docs to Pages | ||
|
|
||
| on: | ||
| # Runs on pushes targeting the default branch | ||
| push: | ||
| branches: ["main"] | ||
| paths: | ||
| - docs/** | ||
|
|
||
| # Allows you to run this workflow manually from the Actions tab | ||
| workflow_dispatch: | ||
|
|
||
| # Sets permissions of the GITHUB_TOKEN to allow deployment to GitHub Pages | ||
| permissions: | ||
| contents: read | ||
| pages: write | ||
| id-token: write | ||
|
|
||
| # Allow only one concurrent deployment, skipping runs queued between the run in-progress and latest queued. | ||
| # However, do NOT cancel in-progress runs as we want to allow these production deployments to complete. | ||
| concurrency: | ||
| group: "pages" | ||
| cancel-in-progress: false | ||
|
|
||
| jobs: | ||
| # Single deploy job since we're just deploying | ||
| deploy: | ||
| environment: | ||
| name: github-pages | ||
| url: ${{ steps.deployment.outputs.page_url }} | ||
| runs-on: ubuntu-latest | ||
| steps: | ||
| - name: Checkout | ||
| uses: actions/checkout@v3 | ||
| - name: Setup Pages | ||
| uses: actions/configure-pages@v3 | ||
| - name: Upload artifact | ||
| uses: actions/upload-pages-artifact@v2 | ||
| with: | ||
| # Upload entire repository | ||
| path: './docs' | ||
| - name: Deploy to GitHub Pages | ||
| id: deployment | ||
| uses: actions/deploy-pages@v2 |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,13 @@ | ||
|  | ||
|
|
||
| # Flux Community Documentation | ||
|
|
||
| Flux is an open source functional data scripting language designed for querying, analyzing, and acting on data. Flux supports multiple data source types, including: | ||
|
|
||
| - Time series databases _(such as InfluxDB and IOx)_ | ||
| - Relational SQL databases _(such as MySQL, PostgreSQL, ClickHouse, etc)_ | ||
| - Local Files or Object Storage Data _(such as CSV, TSV, JSON, etc)_ | ||
|
|
||
| Flux unifies code for querying, processing, writing, and acting on data into a single syntax. | ||
|
|
||
| The language is designed to be usable, readable, flexible, composable, testable, contributable, and shareable. |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,124 @@ | ||
| ## | ||
|
|
||
| - array | ||
| - [array](array.md) | ||
| - bitwise | ||
| - [bitwise](bitwise.md) | ||
| - contrib | ||
| - [naiveBayesClassifier](contrib/RohanSreerama5/naiveBayesClassifier.md) | ||
| - [anomalydetection](contrib/anaisdg/anomalydetection.md) | ||
| - [statsmodels](contrib/anaisdg/statsmodels.md) | ||
| - [alerta](contrib/bonitoo-io/alerta.md) | ||
| - [hex](contrib/bonitoo-io/hex.md) | ||
| - [servicenow](contrib/bonitoo-io/servicenow.md) | ||
| - [tickscript](contrib/bonitoo-io/tickscript.md) | ||
| - [victorops](contrib/bonitoo-io/victorops.md) | ||
| - [zenoss](contrib/bonitoo-io/zenoss.md) | ||
| - [discord](contrib/chobbs/discord.md) | ||
| - [influxdb](contrib/jsternberg/influxdb.md) | ||
| - [clickhouse](contrib/qxip/clickhouse.md) | ||
| - [hash](contrib/qxip/hash.md) | ||
| - [iox](contrib/qxip/iox.md) | ||
| - [logql](contrib/qxip/logql.md) | ||
| - [bigpanda](contrib/rhajek/bigpanda.md) | ||
| - [opsgenie](contrib/sranka/opsgenie.md) | ||
| - [sensu](contrib/sranka/sensu.md) | ||
| - [teams](contrib/sranka/teams.md) | ||
| - [telegram](contrib/sranka/telegram.md) | ||
| - [webexteams](contrib/sranka/webexteams.md) | ||
| - [events](contrib/tomhollingworth/events.md) | ||
| - csv | ||
| - [csv](csv.md) | ||
| - date | ||
| - [date](date.md) | ||
| - [boundaries](date/boundaries.md) | ||
| - dict | ||
| - [dict](dict.md) | ||
| - experimental | ||
| - [experimental](experimental.md) | ||
| - [aggregate](experimental/aggregate.md) | ||
| - [array](experimental/array.md) | ||
| - [bigtable](experimental/bigtable.md) | ||
| - [bitwise](experimental/bitwise.md) | ||
| - [csv](experimental/csv.md) | ||
| - [boundaries](experimental/date/boundaries.md) | ||
| - [dynamic](experimental/dynamic.md) | ||
| - [geo](experimental/geo.md) | ||
| - [http](experimental/http.md) | ||
| - [requests](experimental/http/requests.md) | ||
| - [influxdb](experimental/influxdb.md) | ||
| - [iox](experimental/iox.md) | ||
| - [json](experimental/json.md) | ||
| - [mqtt](experimental/mqtt.md) | ||
| - [oee](experimental/oee.md) | ||
| - [polyline](experimental/polyline.md) | ||
| - [prometheus](experimental/prometheus.md) | ||
| - [query](experimental/query.md) | ||
| - [record](experimental/record.md) | ||
| - [table](experimental/table.md) | ||
| - [usage](experimental/usage.md) | ||
| - generate | ||
| - [generate](generate.md) | ||
| - http | ||
| - [http](http.md) | ||
| - [requests](http/requests.md) | ||
| - influxdata | ||
| - [influxdb](influxdata/influxdb.md) | ||
| - [monitor](influxdata/influxdb/monitor.md) | ||
| - [sample](influxdata/influxdb/sample.md) | ||
| - [schema](influxdata/influxdb/schema.md) | ||
| - [secrets](influxdata/influxdb/secrets.md) | ||
| - [tasks](influxdata/influxdb/tasks.md) | ||
| - [v1](influxdata/influxdb/v1.md) | ||
| - internal | ||
| - [boolean](internal/boolean.md) | ||
| - [debug](internal/debug.md) | ||
| - [gen](internal/gen.md) | ||
| - [influxql](internal/influxql.md) | ||
| - [location](internal/location.md) | ||
| - [promql](internal/promql.md) | ||
| - [testing](internal/testing.md) | ||
| - [testutil](internal/testutil.md) | ||
| - interpolate | ||
| - [interpolate](interpolate.md) | ||
| - join | ||
| - [join](join.md) | ||
| - json | ||
| - [json](json.md) | ||
| - kafka | ||
| - [kafka](kafka.md) | ||
| - math | ||
| - [math](math.md) | ||
| - pagerduty | ||
| - [pagerduty](pagerduty.md) | ||
| - planner | ||
| - [planner](planner.md) | ||
| - profiler | ||
| - [profiler](profiler.md) | ||
| - pushbullet | ||
| - [pushbullet](pushbullet.md) | ||
| - regexp | ||
| - [regexp](regexp.md) | ||
| - runtime | ||
| - [runtime](runtime.md) | ||
| - sampledata | ||
| - [sampledata](sampledata.md) | ||
| - slack | ||
| - [slack](slack.md) | ||
| - socket | ||
| - [socket](socket.md) | ||
| - sql | ||
| - [sql](sql.md) | ||
| - strings | ||
| - [strings](strings.md) | ||
| - system | ||
| - [system](system.md) | ||
| - testing | ||
| - [testing](testing.md) | ||
| - [expect](testing/expect.md) | ||
| - timezone | ||
| - [timezone](timezone.md) | ||
| - types | ||
| - [types](types.md) | ||
| - universe | ||
| - [universe](universe.md) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,78 @@ | ||
| ## `array` package | ||
|
|
||
| Package array provides functions for manipulating array and building tables from arrays. | ||
|
|
||
| Import the `array` package: | ||
|
|
||
| ```flux | ||
| import "array" | ||
| ``` | ||
|
|
||
| ### Functions | ||
|
|
||
| ### `concat()` | ||
|
|
||
| concat appends two arrays and returns a new array. | ||
|
|
||
| #### Function type signature | ||
|
|
||
| ```flux | ||
| (<-arr: [A], v: [A]) => [A] | ||
| ``` | ||
|
|
||
| #### Parameters | ||
|
|
||
| | Parameter | Description | Required | | ||
| | --- | --- | --- | | ||
| | arr | arr: First array. Default is the piped-forward array (`<-`). | No | | ||
| | v | v: Array to append to the first array. | Yes | | ||
| ### `filter()` | ||
|
|
||
| filter iterates over an array, evaluates each element with a predicate function, and then returns | ||
| a new array with only elements that match the predicate. | ||
|
|
||
| #### Function type signature | ||
|
|
||
| ```flux | ||
| (<-arr: [A], fn: (x: A) => bool) => [A] | ||
| ``` | ||
|
|
||
| #### Parameters | ||
|
|
||
| | Parameter | Description | Required | | ||
| | --- | --- | --- | | ||
| | arr | arr: Array to filter. Default is the piped-forward array (`<-`). | No | | ||
| | fn | fn: Predicate function to evaluate on each element. | ||
| The element is represented by `x` in the predicate function. | Yes | | ||
| ### `from()` | ||
|
|
||
| from constructs a table from an array of records. | ||
|
|
||
| #### Function type signature | ||
|
|
||
| ```flux | ||
| (<-rows: [A]) => stream[A] where A: Record | ||
| ``` | ||
|
|
||
| #### Parameters | ||
|
|
||
| | Parameter | Description | Required | | ||
| | --- | --- | --- | | ||
| | rows | rows: Array of records to construct a table with. Default is the piped-forward array (`<-`). | No | | ||
| ### `map()` | ||
|
|
||
| map iterates over an array, applies a function to each element to produce a new element, | ||
| and then returns a new array. | ||
|
|
||
| #### Function type signature | ||
|
|
||
| ```flux | ||
| (<-arr: [A], fn: (x: A) => B) => [B] | ||
| ``` | ||
|
|
||
| #### Parameters | ||
|
|
||
| | Parameter | Description | Required | | ||
| | --- | --- | --- | | ||
| | arr | arr: Array to operate on. Defaults is the piped-forward array (`<-`). | No | | ||
| | fn | fn: Function to apply to elements. The element is represented by `x` in the function. | Yes | |
Oops, something went wrong.